flux

Documentation

Index

• Constants
• type Flux
• type FluxClient
  • func New(osysClient osys.Osys, cliRunner runner.Runner) *FluxClient
  • func (f *FluxClient) CreateHelmReleaseGitRepository(name, source, chartPath, namespace, targetNamespace string) ([]byte, error)
  • func (f *FluxClient) CreateHelmReleaseHelmRepository(name, chart, namespace, targetNamespace string) ([]byte, error)
  • func (f *FluxClient) CreateKustomization(name string, source string, path string, namespace string) ([]byte, error)
  • func (f *FluxClient) CreateSecretGit(name string, repoUrl gitproviders.RepoURL, namespace string) ([]byte, error)
  • func (f *FluxClient) CreateSourceGit(name string, repoUrl gitproviders.RepoURL, branch string, secretRef string, ...) ([]byte, error)
  • func (f *FluxClient) CreateSourceHelm(name string, url string, namespace string) ([]byte, error)
  • func (f *FluxClient) GetAllResourcesStatus(name string, namespace string) ([]byte, error)
  • func (f *FluxClient) GetBinPath() (string, error)
  • func (f *FluxClient) GetExePath() (string, error)
  • func (f *FluxClient) GetLatestStatusAllNamespaces() ([]string, error)
  • func (f *FluxClient) GetVersion() (string, error)
  • func (f *FluxClient) Install(namespace string, export bool) ([]byte, error)
  • func (f *FluxClient) PreCheck() (string, error)
  • func (f *FluxClient) SetupBin()
  • func (f *FluxClient) SuspendOrResumeApp(suspend wego.SuspendActionType, name, namespace string, deploymentType string) ([]byte, error)
  • func (f *FluxClient) Uninstall(namespace string, dryRun bool) error

Constants

const (
	PartOfLabelKey   = "app.kubernetes.io/part-of"
	PartOfLabelValue = "flux"
	VersionLabelKey  = "app.kubernetes.io/version"
)

Types

type Flux

type Flux interface {
	SetupBin()
	GetBinPath() (string, error)
	GetExePath() (string, error)
	Install(namespace string, export bool) ([]byte, error)
	Uninstall(namespace string, export bool) error
	CreateSourceGit(name string, repoUrl gitproviders.RepoURL, branch string, secretRef string, namespace string) ([]byte, error)
	CreateSourceHelm(name string, url string, namespace string) ([]byte, error)
	CreateKustomization(name string, source string, path string, namespace string) ([]byte, error)
	CreateHelmReleaseGitRepository(name, source, path, namespace, targetNamespace string) ([]byte, error)
	CreateHelmReleaseHelmRepository(name, chart, namespace, targetNamespace string) ([]byte, error)
	CreateSecretGit(name string, repoUrl gitproviders.RepoURL, namespace string) ([]byte, error)
	GetVersion() (string, error)
	GetAllResourcesStatus(name string, namespace string) ([]byte, error)
	SuspendOrResumeApp(pause wego.SuspendActionType, name, namespace, deploymentType string) ([]byte, error)
	GetLatestStatusAllNamespaces() ([]string, error)
	PreCheck() (string, error)
}

type FluxClient

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

func New

func New(osysClient osys.Osys, cliRunner runner.Runner) *FluxClient

func (*FluxClient) CreateHelmReleaseGitRepository

func (f *FluxClient) CreateHelmReleaseGitRepository(name, source, chartPath, namespace, targetNamespace string) ([]byte, error)

func (*FluxClient) CreateHelmReleaseHelmRepository

func (f *FluxClient) CreateHelmReleaseHelmRepository(name, chart, namespace, targetNamespace string) ([]byte, error)

func (*FluxClient) CreateKustomization

func (f *FluxClient) CreateKustomization(name string, source string, path string, namespace string) ([]byte, error)

func (*FluxClient) CreateSecretGit

func (f *FluxClient) CreateSecretGit(name string, repoUrl gitproviders.RepoURL, namespace string) ([]byte, error)

CreatSecretGit Creates a Git secret returns the deploy key

func (*FluxClient) CreateSourceGit

func (f *FluxClient) CreateSourceGit(name string, repoUrl gitproviders.RepoURL, branch string, secretRef string, namespace string) ([]byte, error)

func (*FluxClient) CreateSourceHelm

func (f *FluxClient) CreateSourceHelm(name string, url string, namespace string) ([]byte, error)

func (*FluxClient) GetAllResourcesStatus

func (f *FluxClient) GetAllResourcesStatus(name string, namespace string) ([]byte, error)

func (*FluxClient) GetBinPath

func (f *FluxClient) GetBinPath() (string, error)

GetFluxBinPath -

func (*FluxClient) GetExePath

func (f *FluxClient) GetExePath() (string, error)

GetFluxExePath -

func (*FluxClient) GetLatestStatusAllNamespaces

func (f *FluxClient) GetLatestStatusAllNamespaces() ([]string, error)

GetLast log for each flux namespace

func (*FluxClient) GetVersion

func (f *FluxClient) GetVersion() (string, error)

func (*FluxClient) Install

func (f *FluxClient) Install(namespace string, export bool) ([]byte, error)

func (*FluxClient) PreCheck

func (f *FluxClient) PreCheck() (string, error)

func (*FluxClient) SetupBin

func (f *FluxClient) SetupBin()

SetupFluxBin creates flux binary from embedded file if it doesnt already exist

func (*FluxClient) SuspendOrResumeApp

func (f *FluxClient) SuspendOrResumeApp(suspend wego.SuspendActionType, name, namespace string, deploymentType string) ([]byte, error)

func (*FluxClient) Uninstall

func (f *FluxClient) Uninstall(namespace string, dryRun bool) error