input

Documentation

Index

• type InputReconciler
  • func NewInputReconciler(ctx context.Context, multiClusterReconcileFunc MultiClusterReconcileFunc, ...) InputReconciler
• type MultiClusterReconcileFunc
• type SingleClusterReconcileFunc

Types

type InputReconciler

type InputReconciler interface {
	// reconcile the generic resource type in the local cluster.
	// this function is called from generated code.
	ReconcileLocalGeneric(id ezkube.ResourceId) (reconcile.Result, error)

	// reconcile the generic resource type in a remote cluster.
	// this function is called from generated code.
	ReconcileRemoteGeneric(id ezkube.ClusterResourceId) (reconcile.Result, error)
}

the InputReconciler reconciles events for input resources in a single cluster

func NewInputReconciler

func NewInputReconciler(
	ctx context.Context,
	multiClusterReconcileFunc MultiClusterReconcileFunc,
	singleClusterReconcileFunc SingleClusterReconcileFunc,
	reconcileInterval time.Duration,
) InputReconciler

Note(ilackarms): in the current implementation, the constructor also starts the reconciler's event processor in a goroutine. Make sure to cancel the parent context in order to ensure the goroutine started here is gc'ed. only one event will be processed per reconcileInterval.

type MultiClusterReconcileFunc

type MultiClusterReconcileFunc func(id ezkube.ClusterResourceId) (bool, error)

reconcile a resource across multiple clusters. the passed resource can either be a ref to a resource (caused by a deletion), or an actual resource itself. ClusterName will always be set on the object.

type SingleClusterReconcileFunc

type SingleClusterReconcileFunc func(id ezkube.ResourceId) (bool, error)

reconcile a resource in a single cluster. the passed resource can either be a ref to a resource (caused by a deletion), or an actual resource itself.