controller

Documentation

Index

• func AddControllerToManager(baseLogger logging.Logger, mgr manager.Manager, ...) error
• type Controller
  • func NewController(client client.Client, cfg *config.K8SyncerConfiguration, ...) (*Controller, error)
  • func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type DeletionTimestampChangedPredicate
  • func (DeletionTimestampChangedPredicate) Update(e event.UpdateEvent) bool
• type OwnerReferencesChangedPredicate
  • func (OwnerReferencesChangedPredicate) Update(e event.UpdateEvent) bool
• type StorageConfiguration
  • func (sc *StorageConfiguration) Name() string

Functions

func AddControllerToManager

func AddControllerToManager(baseLogger logging.Logger, mgr manager.Manager, cfg *config.K8SyncerConfiguration, syncConfig *config.SyncConfig, persisters map[string]persist.Persister) error

AddControllerToManager register the installation Controller in a manager.

Types

type Controller

type Controller struct {
	Client         client.Client
	Config         *config.K8SyncerConfiguration
	SyncConfig     *config.SyncConfig
	StorageConfigs []*StorageConfiguration
	GVK            schema.GroupVersionKind
	StateDisplay   state.StateDisplay
}

func NewController

func NewController(client client.Client, cfg *config.K8SyncerConfiguration, syncConfig *config.SyncConfig, persisters map[string]persist.Persister) (*Controller, error)

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

Reconcile performs a full reconciliation for the object referred to by the Request. The Controller will requeue the Request to be processed again if an error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

type DeletionTimestampChangedPredicate

type DeletionTimestampChangedPredicate struct {
	predicate.Funcs
}

DeletionTimestampChangedPredicate reacts to changes of the deletion timestamp.

func (DeletionTimestampChangedPredicate) Update

func (DeletionTimestampChangedPredicate) Update(e event.UpdateEvent) bool

type OwnerReferencesChangedPredicate

type OwnerReferencesChangedPredicate struct {
	predicate.Funcs
}

OwnerReferencesChangedPredicate reacts to changes of the owner references.

func (OwnerReferencesChangedPredicate) Update

func (OwnerReferencesChangedPredicate) Update(e event.UpdateEvent) bool

type StorageConfiguration

type StorageConfiguration struct {
	*config.StorageReference
	*config.StorageDefinition
	Persister   persist.Persister
	Transformer persist.Transformer
}

StorageConfiguration is a helper struct to bundle a storage reference with its definition.

func (*StorageConfiguration) Name

func (sc *StorageConfiguration) Name() string