commandexecutorflux

Documentation

Index

• func NewcommandExecutorFlux(executor commandexecutorinterfaces.CommandExecutor) fluxinterfaces.Flux
• type CommandExecutorDeployedFlux
  • func (c *CommandExecutorDeployedFlux) DeleteGitRepository(ctx context.Context, name string, namespace string) error
  • func (c *CommandExecutorDeployedFlux) DeleteHelmRelease(ctx context.Context, name string, namespace string) error
  • func (c *CommandExecutorDeployedFlux) DeleteKustomization(ctx context.Context, name string, namespace string) error
  • func (c *CommandExecutorDeployedFlux) GetCommandExecutor() (commandexecutorinterfaces.CommandExecutor, error)
  • func (c *CommandExecutorDeployedFlux) GetGitRepositoryStatusMessage(ctx context.Context, name string, namespace string) (string, error)
  • func (c *CommandExecutorDeployedFlux) GetHelmReleaseStatusMessage(ctx context.Context, name string, namespace string) (string, error)
  • func (c *CommandExecutorDeployedFlux) GetKustomizationStatusMessage(ctx context.Context, name string, namespace string) (string, error)
  • func (c *CommandExecutorDeployedFlux) GitRepositoryExists(ctx context.Context, name string, namespace string) (bool, error)
  • func (c *CommandExecutorDeployedFlux) HelmReleaseExists(ctx context.Context, name string, namespace string) (bool, error)
  • func (c *CommandExecutorDeployedFlux) KustomizationExists(ctx context.Context, name string, namespace string) (bool, error)
  • func (c *CommandExecutorDeployedFlux) WatchGitRepository(ctx context.Context, name string, namespace string, ...) error
  • func (c *CommandExecutorDeployedFlux) WatchHelmRelease(ctx context.Context, name string, namespace string, ...) error
  • func (c *CommandExecutorDeployedFlux) WatchKustomization(ctx context.Context, name string, namespace string, ...) error
• type CommandExecutorFlux
  • func (c *CommandExecutorFlux) ConfigureFluxInstance(ctx context.Context, cluster kubernetesinterfaces.KubernetesCluster, ...) error
  • func (c *CommandExecutorFlux) GetCommandExecutor() (commandexecutorinterfaces.CommandExecutor, error)
  • func (c *CommandExecutorFlux) GetDeployedFlux(cluster kubernetesinterfaces.KubernetesCluster) (fluxinterfaces.FluxDeployment, error)
  • func (c *CommandExecutorFlux) GetHelm() (helminterfaces.Helm, error)
  • func (c *CommandExecutorFlux) InstallFlux(ctx context.Context, options *fluxparameteroptions.InstalFluxOptions) (fluxinterfaces.FluxDeployment, error)
  • func (c *CommandExecutorFlux) InstallFluxOperatorUsingHelm(ctx context.Context, cluster kubernetesinterfaces.KubernetesCluster, ...) error

Functions

func NewcommandExecutorFlux

func NewcommandExecutorFlux(executor commandexecutorinterfaces.CommandExecutor) fluxinterfaces.Flux

Types

type CommandExecutorDeployedFlux

type CommandExecutorDeployedFlux struct {
	// contains filtered or unexported fields
}

func (*CommandExecutorDeployedFlux) DeleteGitRepository

func (c *CommandExecutorDeployedFlux) DeleteGitRepository(ctx context.Context, name string, namespace string) error

func (*CommandExecutorDeployedFlux) DeleteHelmRelease

func (c *CommandExecutorDeployedFlux) DeleteHelmRelease(ctx context.Context, name string, namespace string) error

func (*CommandExecutorDeployedFlux) DeleteKustomization

func (c *CommandExecutorDeployedFlux) DeleteKustomization(ctx context.Context, name string, namespace string) error

func (*CommandExecutorDeployedFlux) GetCommandExecutor

func (c *CommandExecutorDeployedFlux) GetCommandExecutor() (commandexecutorinterfaces.CommandExecutor, error)

func (*CommandExecutorDeployedFlux) GetGitRepositoryStatusMessage

func (c *CommandExecutorDeployedFlux) GetGitRepositoryStatusMessage(ctx context.Context, name string, namespace string) (string, error)

func (*CommandExecutorDeployedFlux) GetHelmReleaseStatusMessage

func (c *CommandExecutorDeployedFlux) GetHelmReleaseStatusMessage(ctx context.Context, name string, namespace string) (string, error)

func (*CommandExecutorDeployedFlux) GetKustomizationStatusMessage

func (c *CommandExecutorDeployedFlux) GetKustomizationStatusMessage(ctx context.Context, name string, namespace string) (string, error)

func (*CommandExecutorDeployedFlux) GitRepositoryExists

func (c *CommandExecutorDeployedFlux) GitRepositoryExists(ctx context.Context, name string, namespace string) (bool, error)

func (*CommandExecutorDeployedFlux) HelmReleaseExists

func (c *CommandExecutorDeployedFlux) HelmReleaseExists(ctx context.Context, name string, namespace string) (bool, error)

func (*CommandExecutorDeployedFlux) KustomizationExists

func (c *CommandExecutorDeployedFlux) KustomizationExists(ctx context.Context, name string, namespace string) (bool, error)

func (*CommandExecutorDeployedFlux) WatchGitRepository

func (c *CommandExecutorDeployedFlux) WatchGitRepository(ctx context.Context, name string, namespace string, create func(*unstructured.Unstructured), update func(*unstructured.Unstructured), delete func(*unstructured.Unstructured)) error

func (*CommandExecutorDeployedFlux) WatchHelmRelease

func (c *CommandExecutorDeployedFlux) WatchHelmRelease(ctx context.Context, name string, namespace string, create func(*unstructured.Unstructured), update func(*unstructured.Unstructured), delete func(*unstructured.Unstructured)) error

func (*CommandExecutorDeployedFlux) WatchKustomization

func (c *CommandExecutorDeployedFlux) WatchKustomization(ctx context.Context, name string, namespace string, create func(*unstructured.Unstructured), update func(*unstructured.Unstructured), delete func(*unstructured.Unstructured)) error

type CommandExecutorFlux

type CommandExecutorFlux struct {
	// contains filtered or unexported fields
}

func (*CommandExecutorFlux) ConfigureFluxInstance

func (c *CommandExecutorFlux) ConfigureFluxInstance(ctx context.Context, cluster kubernetesinterfaces.KubernetesCluster, namespaceName string) error

func (*CommandExecutorFlux) GetCommandExecutor

func (c *CommandExecutorFlux) GetCommandExecutor() (commandexecutorinterfaces.CommandExecutor, error)

func (*CommandExecutorFlux) GetDeployedFlux

func (c *CommandExecutorFlux) GetDeployedFlux(cluster kubernetesinterfaces.KubernetesCluster) (fluxinterfaces.FluxDeployment, error)

func (*CommandExecutorFlux) GetHelm

func (c *CommandExecutorFlux) GetHelm() (helminterfaces.Helm, error)

func (*CommandExecutorFlux) InstallFlux

func (c *CommandExecutorFlux) InstallFlux(ctx context.Context, options *fluxparameteroptions.InstalFluxOptions) (fluxinterfaces.FluxDeployment, error)

func (*CommandExecutorFlux) InstallFluxOperatorUsingHelm

func (c *CommandExecutorFlux) InstallFluxOperatorUsingHelm(ctx context.Context, cluster kubernetesinterfaces.KubernetesCluster, namespace string) error