internal

Documentation

Index

• func DeletedStateFor[T any, Obj apitypes.FSMResource[T]](_ *fsmReconciler[T, Obj]) *types.State[Obj]
• func NewFSMReconciler[T any, Obj apitypes.FSMResource[T]](name string, log *zap.SugaredLogger, client *io.ClientApplicator, ...) *fsmReconciler[T, Obj]
• type BeforeDelete
• type ClaimReconciler
  • func NewClaimReconciler[T any, Claimed apitypes.ClaimedType[T], U any, Claim apitypes.ClaimType[U]](_ Claimed, claim Claim, client *io.ClientApplicator, scheme *runtime.Scheme, ...) ClaimReconciler[T, Claimed, U, Claim]
  • func (r *ClaimReconciler[T, Claimed, U, Claim]) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Functions

func DeletedStateFor

func DeletedStateFor[T any, Obj apitypes.FSMResource[T]](_ *fsmReconciler[T, Obj]) *types.State[Obj]

func NewFSMReconciler

func NewFSMReconciler[T any, Obj apitypes.FSMResource[T]](
	name string,
	log *zap.SugaredLogger,
	client *io.ClientApplicator,
	scheme *runtime.Scheme,
	initialState *types.State[Obj],
	finalizerState *types.State[Obj],
	managedTypes []schema.GroupVersionKind,
	metrics *metrics.Metrics,
	reconcilerOptions types.ReconcilerOptions[T, Obj],
) *fsmReconciler[T, Obj]

Types

type BeforeDelete

type BeforeDelete[
	T any, Claimed apitypes.ClaimedType[T], U any, Claim apitypes.ClaimType[U],
] func(Claim, Claimed) error

type ClaimReconciler

type ClaimReconciler[T any, Claimed apitypes.ClaimedType[T], U any, Claim apitypes.ClaimType[U]] struct {
	Client *io.ClientApplicator
	Scheme *runtime.Scheme
	Log    *zap.SugaredLogger

	Name string
	// contains filtered or unexported fields
}

func NewClaimReconciler

func NewClaimReconciler[T any, Claimed apitypes.ClaimedType[T], U any, Claim apitypes.ClaimType[U]](
	_ Claimed,
	claim Claim,
	client *io.ClientApplicator,
	scheme *runtime.Scheme,
	log *zap.SugaredLogger,
	beforeDelete BeforeDelete[T, Claimed, U, Claim],
) ClaimReconciler[T, Claimed, U, Claim]

func (*ClaimReconciler[T, Claimed, U, Claim]) Reconcile

func (r *ClaimReconciler[T, Claimed, U, Claim]) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)