reconciler

package

v0.0.1 Latest Latest Go to latest Published: Aug 18, 2020 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation ¶

Index ¶

type CRSanityChecker
type ConfigurationManager
type CrCrud
type CrManager
type PerishablesSynchronizer
type Reconciler
- func NewReconciler(crManager CrManager, log logr.Logger, client client.Client, ...) *Reconciler
type ResourcesProvider
type WatchRegistrator

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CRSanityChecker ¶

type CRSanityChecker interface {
	SanityCheck(cr controllerutil.Object, reqLogger logr.Logger) (*reconcile.Result, error)
}

type ConfigurationManager ¶

type ConfigurationManager interface {
	CreateOperatorConfig(cr controllerutil.Object) error
	IsOperatorConfigMissing() (bool, error)
}

type CrCrud ¶

type CrCrud interface {
	Create() runtime.Object
	Update(object runtime.Object) error
	Get(name types.NamespacedName) (controllerutil.Object, error)
	Status(object runtime.Object) *sdkapi.Status
	GetFinalizers(object runtime.Object) []string
	SetFinalizers(object runtime.Object, finalizers []string)
}

type CrManager ¶

type CrManager interface {
	CrCrud
	ResourcesProvider
	WatchRegistrator
	PerishablesSynchronizer
	ConfigurationManager
	CRSanityChecker
}

CrManager defines interface that needs to be provided for the reconciler to operate

type PerishablesSynchronizer ¶

type PerishablesSynchronizer interface {
	Sync() error
}

type Reconciler ¶

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

Reconciler is responsible for performing deployment reconciliation

func NewReconciler ¶

func NewReconciler(crManager CrManager, log logr.Logger, client client.Client, callbackDispatcher *sdk.CallbackDispatcher, scheme *runtime.Scheme, createVersionLabel string, updateVersionLabel string, lastAppliedConfigAnnotation string, perishablesSyncInterval time.Duration, finalizerName string) *Reconciler

NewReconciler creates new Reconciler instance configured with given parameters

func (*Reconciler) AddCallback ¶

func (r *Reconciler) AddCallback(obj runtime.Object, cb sdk.ReconcileCallback)

AddCallback registers a callback for given object type

func (*Reconciler) CheckDegraded ¶

func (r *Reconciler) CheckDegraded(logger logr.Logger, cr runtime.Object) (bool, error)

CheckDegraded checks whether the deployment is degraded and updates CR status conditions accordingly

func (*Reconciler) CheckForOrphans ¶

func (r *Reconciler) CheckForOrphans(logger logr.Logger, cr runtime.Object) (bool, error)

CheckForOrphans checks whether there are any orphaned resources (ones that exist in the cluster but shouldn't)

func (*Reconciler) CheckUpgrade ¶

func (r *Reconciler) CheckUpgrade(logger logr.Logger, cr runtime.Object, targetVersion string) error

CheckUpgrade checks whether an upgrade should be performed

func (*Reconciler) CleanupUnusedResources ¶

func (r *Reconciler) CleanupUnusedResources(logger logr.Logger, cr controllerutil.Object) error

CleanupUnusedResources removes unused resources

func (*Reconciler) CrError ¶

func (r *Reconciler) CrError(cr runtime.Object) error

CrError sets the CR's phase to "Error"

func (*Reconciler) CrInit ¶

func (r *Reconciler) CrInit(cr controllerutil.Object, operatorVersion string) error

CrInit initializes the CR and moves it to CR to "Deploying" status

func (*Reconciler) CrSetVersion ¶

func (r *Reconciler) CrSetVersion(cr runtime.Object, version string) error

func (*Reconciler) CrUpdate ¶

func (r *Reconciler) CrUpdate(phase sdkapi.Phase, cr runtime.Object) error

CrUpdate sets given phase on the CR and updates it in the cluster

func (*Reconciler) GetAllDeployments ¶

func (r *Reconciler) GetAllDeployments(cr runtime.Object) ([]*appsv1.Deployment, error)

GetAllDeployments retrieves all deployments associated to the given CR object

func (*Reconciler) InvokeCallbacks ¶

func (r *Reconciler) InvokeCallbacks(l logr.Logger, cr runtime.Object, s sdk.ReconcileState, desiredObj, currentObj runtime.Object) error

InvokeCallbacks executes callbacks registered

func (*Reconciler) InvokeDeleteCallbacks ¶

func (r *Reconciler) InvokeDeleteCallbacks(logger logr.Logger, cr runtime.Object) error

InvokeDeleteCallbacks executes operator deletion callbacks

func (*Reconciler) Reconcile ¶

func (r *Reconciler) Reconcile(request reconcile.Request, operatorVersion string, reqLogger logr.Logger) (reconcile.Result, error)

Reconcile performs request reconciliation

func (*Reconciler) ReconcileCreate ¶

func (r *Reconciler) ReconcileCreate(logger logr.Logger, cr controllerutil.Object, operatorVersion string) (reconcile.Result, error)

ReconcileCreate performes Create operation

func (*Reconciler) ReconcileDelete ¶

func (r *Reconciler) ReconcileDelete(logger logr.Logger, cr controllerutil.Object, finalizerName string) (reconcile.Result, error)

ReconcileDelete executes Delete operation

func (*Reconciler) ReconcileError ¶

func (r *Reconciler) ReconcileError(cr runtime.Object, message string) (reconcile.Result, error)

ReconcileError Marks CR as failed

func (*Reconciler) ReconcileUpdate ¶

func (r *Reconciler) ReconcileUpdate(logger logr.Logger, cr controllerutil.Object, operatorVersion string) (reconcile.Result, error)

ReconcileUpdate executes Update operation

func (*Reconciler) SetController ¶

func (r *Reconciler) SetController(controller controller.Controller)

SetController sets controller

func (*Reconciler) WatchCR ¶

func (r *Reconciler) WatchCR() error

WatchCR registers watch for the managed CR

func (*Reconciler) WatchDependantResources ¶

func (r *Reconciler) WatchDependantResources(cr runtime.Object) error

WatchDependantResources registers watches for dependant resource types

func (*Reconciler) WatchResourceTypes ¶

func (r *Reconciler) WatchResourceTypes(resources ...runtime.Object) error

WatchResourceTypes registers watches for given resources types

type ResourcesProvider ¶

type ResourcesProvider interface {
	GetAllResources(cr runtime.Object) ([]runtime.Object, error)
	GetDependantResourcesListObjects() []runtime.Object
}

type WatchRegistrator ¶

type WatchRegistrator interface {
	Watch() error
}

Source Files ¶

View all Source files

reconciler.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL