reconcilers

Documentation

Index

• Constants
• func ARMPerResourceSecretAnnotationChangedPredicate() predicate.Predicate
• func ARMReconcilerAnnotationChangedPredicate() predicate.Predicate
• func ClassifyResolverError(err error) error
• func GetReconcilePolicy(obj genruntime.MetaObject, log logr.Logger) annotations.ReconcilePolicyValue
• func HasAnnotationChanged(old *string, new *string) bool
• func HasReconcilePolicyAnnotationChanged(old *string, new *string) bool
• func LogObj(log logr.Logger, level int, note string, obj genruntime.MetaObject)
• func ParseReconcilePolicy(policy string) (annotations.ReconcilePolicyValue, error)
• type ARMOwnedResourceReconcilerCommon
  • func (r *ARMOwnedResourceReconcilerCommon) ApplyOwnership(ctx context.Context, log logr.Logger, obj genruntime.ARMOwnedMetaObject) error
  • func (r *ARMOwnedResourceReconcilerCommon) ClaimResource(ctx context.Context, log logr.Logger, obj genruntime.ARMOwnedMetaObject) error
  • func (r *ARMOwnedResourceReconcilerCommon) NeedsToWaitForOwner(ctx context.Context, log logr.Logger, obj genruntime.ARMOwnedMetaObject) (bool, error)
• type ActionFunc
• type ReconcilerCommon

Constants

const (
	PollerResumeTokenAnnotation = "serviceoperator.azure.com/poller-resume-token"
	PollerResumeIDAnnotation    = "serviceoperator.azure.com/poller-resume-id"
	LatestReconciledGeneration  = "serviceoperator.azure.com/latest-reconciled-generation"
)

Annotation labels, used to store metadata about the state of the resource.

Functions

func ARMPerResourceSecretAnnotationChangedPredicate

func ARMPerResourceSecretAnnotationChangedPredicate() predicate.Predicate

ARMPerResourceSecretAnnotationChangedPredicate creates a predicate that emits events when annotations interesting to the generic ARM reconciler are changed

func ARMReconcilerAnnotationChangedPredicate

func ARMReconcilerAnnotationChangedPredicate() predicate.Predicate

ARMReconcilerAnnotationChangedPredicate creates a predicate that emits events when annotations interesting to the generic ARM reconciler are changed

func ClassifyResolverError

func ClassifyResolverError(err error) error

func GetReconcilePolicy

func GetReconcilePolicy(obj genruntime.MetaObject, log logr.Logger) annotations.ReconcilePolicyValue

GetReconcilePolicy gets the reconcile-policy from the ReconcilePolicy

func HasAnnotationChanged

func HasAnnotationChanged(old *string, new *string) bool

HasAnnotationChanged returns true if the annotation has changed

func HasReconcilePolicyAnnotationChanged

func HasReconcilePolicyAnnotationChanged(old *string, new *string) bool

HasReconcilePolicyAnnotationChanged returns true if the reconcile-policy annotation has changed in a way that needs to trigger a reconcile.

func LogObj

func LogObj(log logr.Logger, level int, note string, obj genruntime.MetaObject)

LogObj logs the obj

func ParseReconcilePolicy

func ParseReconcilePolicy(policy string) (annotations.ReconcilePolicyValue, error)

ParseReconcilePolicy parses the provided reconcile policy.

Types

type ARMOwnedResourceReconcilerCommon

type ARMOwnedResourceReconcilerCommon struct {
	ReconcilerCommon
	ResourceResolver *resolver.Resolver
}

func (*ARMOwnedResourceReconcilerCommon) ApplyOwnership

func (r *ARMOwnedResourceReconcilerCommon) ApplyOwnership(ctx context.Context, log logr.Logger, obj genruntime.ARMOwnedMetaObject) error

func (*ARMOwnedResourceReconcilerCommon) ClaimResource

func (r *ARMOwnedResourceReconcilerCommon) ClaimResource(ctx context.Context, log logr.Logger, obj genruntime.ARMOwnedMetaObject) error

ClaimResource ensures that the owner reference is set

func (*ARMOwnedResourceReconcilerCommon) NeedsToWaitForOwner

func (r *ARMOwnedResourceReconcilerCommon) NeedsToWaitForOwner(ctx context.Context, log logr.Logger, obj genruntime.ARMOwnedMetaObject) (bool, error)

NeedsToWaitForOwner returns false if the owner doesn't need to be waited for, and true if it does.

type ActionFunc

type ActionFunc = func(ctx context.Context) (ctrl.Result, error)

TODO: It's not clear to me that this file holds any value...

type ReconcilerCommon

type ReconcilerCommon struct {
	KubeClient          kubeclient.Client
	PositiveConditions  *conditions.PositiveConditionBuilder
	ExpressionEvaluator asocel.ExpressionEvaluator
}