reconciler

Feb 22, 2022

Changes in this version

type ReconcilerOpts

+ PatchCalculateOptions []patch.CalculateOption

+ PatchMaker patch.Maker

type ResourceReconcilerOption

+ func WithPatchCalculateOptions(options ...patch.CalculateOption) ResourceReconcilerOption

+ func WithPatchMaker(maker patch.Maker) ResourceReconcilerOption

Nov 29, 2021

Changes in this version

+ func MatchImmutableNoStatefulSet(errorMessage string) bool

Nov 19, 2021

Changes in this version

type NativeReconcilerOpt

+ func NativeReconcilerWithRetriableErrorFunc(retriableErrorFunc func(error) bool) NativeReconcilerOpt

+ func NativeReconcilerWithRetryBackoff(backoff wait.Backoff) NativeReconcilerOpt

Nov 6, 2021

Changes in this version

+ type DesiredStateWithGetter interface

+ GetDesiredState func() DesiredState

+ type MultipleDesiredStates []DesiredState

+ func (s MultipleDesiredStates) BeforeCreate(desired runtime.Object) error

+ func (s MultipleDesiredStates) BeforeDelete(desired runtime.Object) error

+ func (s MultipleDesiredStates) BeforeUpdate(current, desired runtime.Object) error

+ func (s MultipleDesiredStates) GetCreateptions() []runtimeClient.CreateOption

+ func (s MultipleDesiredStates) GetDeleteOptions() []runtimeClient.DeleteOption

+ func (s MultipleDesiredStates) GetDesiredState() DesiredState

+ func (s MultipleDesiredStates) GetUpdateOptions() []runtimeClient.UpdateOption

+ func (s MultipleDesiredStates) ShouldCreate(desired runtime.Object) (bool, error)

+ func (s MultipleDesiredStates) ShouldDelete(desired runtime.Object) (bool, error)

+ func (s MultipleDesiredStates) ShouldUpdate(current, desired runtime.Object) (bool, error)

Oct 18, 2021

Changes in this version

+ func MatchImmutableErrorMessages(errorMessage string) bool

+ type ErrorMessageCondition func(string) bool

type ReconcilerOpts

+ RecreateErrorMessageCondition ErrorMessageCondition

type ResourceReconcilerOption

+ func WithRecreateErrorMessageCondition(condition ErrorMessageCondition) ResourceReconcilerOption

Sep 29, 2021

Changes in this version

+ type ComponentReconcilers []ComponentReconciler

+ func (c ComponentReconcilers) Get(order utils.ResourceOrder) []ComponentReconciler

type Dispatcher

+ ForceResourceOrder utils.ResourceOrder

Aug 12, 2021

Changes in this version

type ReconcilerOpts

+ RecreatePropagationPolicy client.PropagationPolicy

May 21, 2021

Changes in this version

+ func KeepLabelsAndAnnotationsModifer(current, desired runtime.Object) error

+ func KeepServiceAccountTokenReferences(current, desired runtime.Object) error

+ func ServiceIPModifier(current, desired runtime.Object) error

+ type DynamicDesiredState struct

+ BeforeCreateFunc func(desired runtime.Object) error

+ BeforeDeleteFunc func(current runtime.Object) error

+ BeforeUpdateFunc func(current, desired runtime.Object) error

+ CreateOptions []runtimeClient.CreateOption

+ DeleteOptions []runtimeClient.DeleteOption

+ DesiredState DesiredState

+ ShouldCreateFunc func(desired runtime.Object) (bool, error)

+ ShouldDeleteFunc func(desired runtime.Object) (bool, error)

+ ShouldUpdateFunc func(current, desired runtime.Object) (bool, error)

+ UpdateOptions []runtimeClient.UpdateOption

+ func (s DynamicDesiredState) BeforeCreate(desired runtime.Object) error

+ func (s DynamicDesiredState) BeforeDelete(current runtime.Object) error

+ func (s DynamicDesiredState) BeforeUpdate(current, desired runtime.Object) error

+ func (s DynamicDesiredState) GetCreateptions() []runtimeClient.CreateOption

+ func (s DynamicDesiredState) GetDeleteOptions() []runtimeClient.DeleteOption

+ func (s DynamicDesiredState) GetDesiredState() DesiredState

+ func (s DynamicDesiredState) GetUpdateOptions() []runtimeClient.UpdateOption

+ func (s DynamicDesiredState) ShouldCreate(desired runtime.Object) (bool, error)

+ func (s DynamicDesiredState) ShouldDelete(desired runtime.Object) (bool, error)

+ func (s DynamicDesiredState) ShouldUpdate(current, desired runtime.Object) (bool, error)

May 14, 2021

Changes in this version

type NativeReconcilerOpt

+ func NativeReconcilerWithModifier(modifierFunc resources.ObjectModifierWithParentFunc) NativeReconcilerOpt

Mar 16, 2021

Changes in this version

+ const DefaultRecreateRequeueDelay

+ var DefaultRecreateEnabledGroupKinds = []schema.GroupKind

type ReconcilerOpts

+ RecreateEnabledResourceCondition RecreateResourceCondition

+ RecreateErrorMessageSubstring *string

+ RecreateImmediately bool

+ RecreateRequeueDelay *int32

+ type RecreateResourceCondition func(kind schema.GroupVersionKind, status metav1.Status) bool

type ResourceReconcilerOption

+ func WithRecreateEnabledFor(condition RecreateResourceCondition) ResourceReconcilerOption

+ func WithRecreateEnabledForAll() ResourceReconcilerOption

+ func WithRecreateEnabledForNothing() ResourceReconcilerOption

+ func WithRecreateErrorMessageIgnored() ResourceReconcilerOption

+ func WithRecreateErrorMessageSubstring(substring string) ResourceReconcilerOption

+ func WithRecreateImmediately() ResourceReconcilerOption

+ func WithRecreateRequeueDelay(delay int32) ResourceReconcilerOption

Sep 28, 2020

Changes in this version

+ type ComponentLifecycle interface

+ OnFinished func(object runtime.Object) error

+ type ComponentWithStatus interface

+ IsEnabled func(object runtime.Object) bool

+ IsSkipped func(object runtime.Object) bool

+ Update func(object runtime.Object, status types.ReconcileStatus, msg string) error

Sep 8, 2020

Changes in this version

+ var DefaultBackoff = wait.Backoff

+ func IgnoreManagedFields() patch.CalculateOption

+ func IstioSidecarInjectorExistsCheck(c client.Client, namespace string) wait.CustomResourceConditionCheck

+ type ConditionChecker struct

+ func NewConditionChecker(client client.Client, scheme *runtime.Scheme, log logr.Logger) *ConditionChecker

+ func (c *ConditionChecker) CheckResourceConditions(conditions []ResourceCondition, backoff *wait.Backoff) error

+ type ConditionType string

type GenericResourceReconciler

+ func NewGenericReconciler(client runtimeClient.Client, log logr.Logger, opts ReconcilerOpts) *GenericResourceReconciler

type NativeReconciler

+ func NewNativeReconcilerWithDefaults(component string, client client.Client, scheme *runtime.Scheme, ...) *NativeReconciler

type NativeReconcilerOpt

+ func NativeReconcilerWithWait(backoff *wait.Backoff) NativeReconcilerOpt

+ type ObjectKeyWithGVK struct

+ GVK schema.GroupVersionKind

+ ObjectKey client.ObjectKey

+ type PendingStatusPredicate struct

+ func (PendingStatusPredicate) Update(e event.UpdateEvent) bool

type ResourceBuilder

+ func GetResourceBuildersFromObjects(objects []runtime.Object, state DesiredState, ...) ([]ResourceBuilder, error)

+ type ResourceCondition struct

+ Checks []wait.ResourceConditionCheck

+ CustomChecks []wait.CustomResourceConditionCheck

+ Description string

+ ID string

+ Object *ObjectKeyWithGVK

+ type SpecChangePredicate struct

+ func (SpecChangePredicate) Update(e event.UpdateEvent) bool

Aug 14, 2020

Changes in this version

+ const ReconciledObjectStateAbsent

+ const ReconciledObjectStatePresent

+ const ReconciledObjectStatePurged

+ func EnqueueByOwnerAnnotationMapper() handler.Mapper

type DesiredState

+ BeforeCreate func(desired runtime.Object) error

+ BeforeDelete func(current runtime.Object) error

type DesiredStateHook

+ func (d DesiredStateHook) BeforeCreate(desired runtime.Object) error

+ func (d DesiredStateHook) BeforeDelete(current runtime.Object) error

+ type DesiredStateShouldCreate interface

+ ShouldCreate func(desired runtime.Object) (bool, error)

+ type DesiredStateShouldDelete interface

+ ShouldDelete func(desired runtime.Object) (bool, error)

+ type DesiredStateShouldUpdate interface

+ ShouldUpdate func(current, desired runtime.Object) (bool, error)

+ type DesiredStateWithCreateOptions interface

+ GetCreateOptions func() []runtimeClient.CreateOption

+ type DesiredStateWithDeleteOptions interface

+ GetDeleteOptions func() []runtimeClient.DeleteOption

+ type DesiredStateWithStaticState interface

+ DesiredState func() StaticDesiredState

+ type DesiredStateWithUpdateOptions interface

+ GetUpdateOptions func() []runtimeClient.UpdateOption

type Dispatcher

+ func (r *Dispatcher) SetupAdditionalWatches(c controller.Controller) error

type NativeReconciler

+ func (rec *NativeReconciler) GetReconciledObjectWithState(state reconciledObjectState) []runtime.Object

type NativeReconcilerOpt

+ func NativeReconcilerSetRESTMapper(mapper meta.RESTMapper) NativeReconcilerOpt

+ type PurgeTypesFunc func() []schema.GroupVersionKind

+ type ResourceOwnerWithControlNamespace interface

+ GetControlNamespace func() string

+ type ResourceTranslate func(runtime.Object) (parent ResourceOwner, config interface{})

+ type SkipCreatePredicate struct

+ func (SkipCreatePredicate) Create(e event.CreateEvent) bool

+ type SkipDeletePredicate struct

+ func (SkipDeletePredicate) Delete(e event.DeleteEvent) bool

+ type SkipUpdatePredicate struct

+ func (SkipUpdatePredicate) Update(e event.UpdateEvent) bool

type StaticDesiredState

+ const StateCreated

+ func (s StaticDesiredState) BeforeCreate(desired runtime.Object) error

+ func (s StaticDesiredState) BeforeDelete(current runtime.Object) error

+ type Watches interface

+ SetupAdditionalWatches func(c controller.Controller) error

Mar 17, 2020

Changes in this version

type NativeReconcilerOpt

+ func NativeReconcilerSetControllerRef() NativeReconcilerOpt

Feb 18, 2020

Changes in this version

+ const BanzaiCloudManagedComponent

+ type CombinedResult struct

+ Err error

+ Result reconcile.Result

+ func (c *CombinedResult) Combine(sub *reconcile.Result, err error)

+ func (c *CombinedResult) CombineErr(err error)

+ type ComponentReconciler interface

+ Reconcile func(object runtime.Object) (*reconcile.Result, error)

+ RegisterWatches func(*builder.Builder)

+ type DefaultReconciledComponent struct

+ func (d *DefaultReconciledComponent) PurgeTypes() []schema.GroupVersionKind

+ func (d *DefaultReconciledComponent) RegisterWatches(b *builder.Builder)

+ func (d *DefaultReconciledComponent) ResourceBuilders(parent ResourceOwner, object interface{}) []ResourceBuilder

+ type Dispatcher struct

+ CompletionHandler func(runtime.Object, ctrl.Result, error) (ctrl.Result, error)

+ ComponentReconcilers []ComponentReconciler

+ Log logr.Logger

+ ResourceFilter func(runtime.Object) (bool, error)

+ ResourceGetter func(req ctrl.Request) (runtime.Object, error)

+ func (r *Dispatcher) Handle(object runtime.Object) (ctrl.Result, error)

+ func (r *Dispatcher) Reconcile(req ctrl.Request) (ctrl.Result, error)

+ func (r *Dispatcher) RegisterWatches(b *builder.Builder) *builder.Builder

type GenericResourceReconciler

+ func (r *GenericResourceReconciler) CreateIfNotExist(desired runtime.Object) (bool, runtime.Object, error)

+ type NativeReconciledComponent interface

+ PurgeTypes func() []schema.GroupVersionKind

+ RegisterWatches func(*builder.Builder)

+ ResourceBuilders func(parent ResourceOwner, object interface{}) []ResourceBuilder

+ func NewReconciledComponent(b ResourceBuilders, w func(b *builder.Builder), ...) NativeReconciledComponent

+ type NativeReconciler struct

+ func NewNativeReconciler(componentName string, rec *GenericResourceReconciler, client client.Client, ...) *NativeReconciler

+ func (rec *NativeReconciler) Reconcile(owner runtime.Object) (*reconcile.Result, error)

+ func (rec *NativeReconciler) RegisterWatches(b *builder.Builder)

+ type NativeReconcilerOpt func(*NativeReconciler)

+ func NativeReconcilerWithScheme(scheme *runtime.Scheme) NativeReconcilerOpt

+ type ReconcileRetry struct

+ DefaultWait time.Duration

+ MaxRetries int

+ func (r *ReconcileRetry) Reconcile(component func() (*reconcile.Result, error)) error

type ReconcilerOpts

+ Log logr.Logger

+ Scheme *runtime.Scheme

+ type ResourceBuilder func() (runtime.Object, DesiredState, error)

+ type ResourceBuilders func(parent ResourceOwner, object interface{}) []ResourceBuilder

+ type ResourceOwner interface

+ GetControlNamespace func() string

+ type ResourceReconciler interface

+ CreateIfNotExist func(runtime.Object) (created bool, object runtime.Object, err error)

+ ReconcileResource func(runtime.Object, DesiredState) (*reconcile.Result, error)

+ func NewReconcilerWith(client runtimeClient.Client, opts ...func(reconciler *ReconcilerOpts)) ResourceReconciler

+ type ResourceReconcilerOption func(*ReconcilerOpts)

+ func WithEnableRecreateWorkload() ResourceReconcilerOption

+ func WithLog(log logr.Logger) ResourceReconcilerOption

+ func WithScheme(scheme *runtime.Scheme) ResourceReconcilerOption

Jan 10, 2020

Changes in this version

+ type DesiredState interface

+ BeforeUpdate func(object runtime.Object) error

+ type DesiredStateHook func(object runtime.Object) error

+ func (d DesiredStateHook) BeforeUpdate(object runtime.Object) error

+ type GenericResourceReconciler struct

+ Client runtimeClient.Client

+ Log logr.Logger

+ Options ReconcilerOpts

+ func NewReconciler(client runtimeClient.Client, log logr.Logger, opts ReconcilerOpts) *GenericResourceReconciler

+ func (r *GenericResourceReconciler) CreateResource(desired runtime.Object) error

+ func (r *GenericResourceReconciler) ReconcileResource(desired runtime.Object, desiredState DesiredState) (*reconcile.Result, error)

+ type ReconcilerOpts struct

+ EnableRecreateWorkloadOnImmutableFieldChange bool

+ EnableRecreateWorkloadOnImmutableFieldChangeHelp string

+ type StaticDesiredState string

+ const StateAbsent

+ const StatePresent

+ func (s StaticDesiredState) BeforeUpdate(object runtime.Object) error