controller

Oct 14, 2026

Changes in this version

+ const DefaultTransientGrace

+ func AnnotationChanged(key string) predicate.Predicate

+ func HasAnnotation(key string) predicate.Predicate

+ func HasLabel(selector labels.Selector) predicate.Predicate

+ func IsTransient(err error) bool

+ func SkipDeletion() predicate.Predicate

+ func UpdateStatus(ctx context.Context, c client.Client, obj client.Object) error

+ type Backoff struct

+ Factor float64

+ Initial time.Duration

+ Max time.Duration

+ func (b Backoff) Next(attempt int) time.Duration

+ type ClusterClientManager struct

+ func NewClusterClientManager(scheme *runtime.Scheme, logger *slog.Logger) *ClusterClientManager

+ func (m *ClusterClientManager) Get(cfg ClusterConfig) (client.Client, error)

+ func (m *ClusterClientManager) GetDefault() (client.Client, error)

+ func (m *ClusterClientManager) Refresh(clusterID string) error

+ type ClusterConfig struct

+ Context string

+ ID string

+ KubeconfigPath string

+ type FinalizeFunc func(ctx context.Context, obj T) error

+ type ReconcileFunc func(ctx context.Context, obj T) (Result, error)

+ type Reconciler struct

+ Client client.Client

+ Finalizer string

+ Log *slog.Logger

+ Recorder record.EventRecorder

+ Scheme *runtime.Scheme

+ TransientGrace time.Duration

+ func (r *Reconciler[T]) Run(ctx context.Context, req ctrl.Request, blank T, reconcile ReconcileFunc[T], ...) (Result, error)

+ func (r *Reconciler[T]) SetupWithManager(mgr ctrl.Manager, concrete T, rec reconcile.Reconciler, opts SetupOptions) error

+ type Result = ctrl.Result

+ func Done() Result

+ func Requeue(after time.Duration) Result

+ func Stop() Result

+ type SetupOptions struct

+ ExtraPredicates []predicate.Predicate

+ Owns []client.Object

+ SkipDeletion bool

+ Watches []WatchSpec

+ type WatchSpec struct

+ Handler handler.EventHandler

+ Object client.Object