stub

Documentation

Index

• func CreateOrUpdate(cr *v1alpha1.Flux, existingObjs []runtime.Object, desiredObjs []runtime.Object) error
• func DesiredFluxObjects(cr *v1alpha1.Flux) ([]runtime.Object, error)
• func ExistingFluxObjects(cr *v1alpha1.Flux) (existing []runtime.Object, err error)
• func GarbageCollectResources(cr *v1alpha1.Flux, existingObjs []runtime.Object, desiredObjs []runtime.Object) error
• func ListForFlux(cr *v1alpha1.Flux, list sdk.Object) error
• func NewHandler() sdk.Handler
• func SynchronizeFluxState(cr *v1alpha1.Flux) error
• type Handler
  • func (h *Handler) Handle(ctx context.Context, event sdk.Event) (err error)

Functions

func CreateOrUpdate

func CreateOrUpdate(cr *v1alpha1.Flux, existingObjs []runtime.Object, desiredObjs []runtime.Object) error

Create or update desiredObjs based on the current state in existingObjs

func DesiredFluxObjects

func DesiredFluxObjects(cr *v1alpha1.Flux) ([]runtime.Object, error)

Create flux, tiller, and helm-operator instances from a CR and return them as a list of objects.

func ExistingFluxObjects

func ExistingFluxObjects(cr *v1alpha1.Flux) (existing []runtime.Object, err error)

Find all resources that currently exist for the CR.

func GarbageCollectResources

func GarbageCollectResources(cr *v1alpha1.Flux, existingObjs []runtime.Object, desiredObjs []runtime.Object) error

Remove any resources that should no longer exist. If a CR is completed deleted, it will be deleted automatically by Kubernetes finalizers. This method deletes resources that need to be deleted if a CR is updated and a resource is obsolete, e.g., helmOperator.enabled is changed from true to false.

func ListForFlux

func ListForFlux(cr *v1alpha1.Flux, list sdk.Object) error

List all resources of a certain type for a CR.

func NewHandler

func NewHandler() sdk.Handler

func SynchronizeFluxState

func SynchronizeFluxState(cr *v1alpha1.Flux) error

Create a flux and tiller with all of the proper RBAC settings.

Types

type Handler

type Handler struct {
}

func (*Handler) Handle

func (h *Handler) Handle(ctx context.Context, event sdk.Event) (err error)