fluxv2

Documentation

Index

• type Fluxv2Provider
  • func NewFluxv2Provider(ctx context.Context, cid, app, cluster, level, namespace string) (*Fluxv2Provider, error)
  • func (p *Fluxv2Provider) Apply(ctx context.Context, name string, ref interface{}, content []byte) (interface{}, error)
  • func (p *Fluxv2Provider) ApplyConfig(ctx context.Context, config interface{}) error
  • func (p *Fluxv2Provider) ApplyStatusCR(ctx context.Context, name string, content []byte) error
  • func (p *Fluxv2Provider) CleanClientProvider() error
  • func (p *Fluxv2Provider) Commit(ctx context.Context, ref interface{}) error
  • func (p *Fluxv2Provider) Create(name string, ref interface{}, content []byte) (interface{}, error)
  • func (p *Fluxv2Provider) Delete(name string, ref interface{}, content []byte) (interface{}, error)
  • func (p *Fluxv2Provider) DeleteConfig(ctx context.Context, config interface{}) error
  • func (p *Fluxv2Provider) DeleteStatusCR(ctx context.Context, name string, content []byte) error
  • func (p *Fluxv2Provider) Get(ctx context.Context, name string, gvkRes []byte) ([]byte, error)
  • func (p *Fluxv2Provider) IsReachable() error
  • func (p *Fluxv2Provider) StartClusterWatcher(ctx context.Context) error
  • func (m *Fluxv2Provider) TagResource(res []byte, label map[string]string) ([]byte, error)

Types

type Fluxv2Provider

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

Connection is for a cluster

func NewFluxv2Provider

func NewFluxv2Provider(ctx context.Context, cid, app, cluster, level, namespace string) (*Fluxv2Provider, error)

func (*Fluxv2Provider) Apply

func (p *Fluxv2Provider) Apply(ctx context.Context, name string, ref interface{}, content []byte) (interface{}, error)

Apply resource to the cluster

func (*Fluxv2Provider) ApplyConfig

func (p *Fluxv2Provider) ApplyConfig(ctx context.Context, config interface{}) error

Create GitRepository and Kustomization CR's for Flux

func (*Fluxv2Provider) ApplyStatusCR

func (p *Fluxv2Provider) ApplyStatusCR(ctx context.Context, name string, content []byte) error

ApplyStatusCR applies status CR

func (*Fluxv2Provider) CleanClientProvider

func (p *Fluxv2Provider) CleanClientProvider() error

func (*Fluxv2Provider) Commit

func (p *Fluxv2Provider) Commit(ctx context.Context, ref interface{}) error

Commit resources to the cluster

func (*Fluxv2Provider) Create

func (p *Fluxv2Provider) Create(name string, ref interface{}, content []byte) (interface{}, error)

Creates a new resource if the not already existing

func (*Fluxv2Provider) Delete

func (p *Fluxv2Provider) Delete(name string, ref interface{}, content []byte) (interface{}, error)

Delete resource from the cluster

func (*Fluxv2Provider) DeleteConfig

func (p *Fluxv2Provider) DeleteConfig(ctx context.Context, config interface{}) error

Delete GitRepository and Kustomization CR's for Flux

func (*Fluxv2Provider) DeleteStatusCR

func (p *Fluxv2Provider) DeleteStatusCR(ctx context.Context, name string, content []byte) error

DeleteStatusCR deletes status CR

func (*Fluxv2Provider) Get

func (p *Fluxv2Provider) Get(ctx context.Context, name string, gvkRes []byte) ([]byte, error)

Get resource from the cluster

func (*Fluxv2Provider) IsReachable

func (p *Fluxv2Provider) IsReachable() error

IsReachable cluster reachablity test

func (*Fluxv2Provider) StartClusterWatcher

func (p *Fluxv2Provider) StartClusterWatcher(ctx context.Context) error

StartClusterWatcher watches for CR changes in git location

func (*Fluxv2Provider) TagResource

func (m *Fluxv2Provider) TagResource(res []byte, label map[string]string) ([]byte, error)