Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files