Versions in this module Expand all Collapse all v0 v0.14.0 Mar 22, 2025 Changes in this version + const DefaultMaxConcurrentReconciles + const MessageShortenLength + func ApplyControllerBuilderOptions(builder *builder.Builder, funcs ...ControllerBuilderOption) *builder.Builder + func BuilderOptions(opts ...BuilderOptionFunc) controller.Options + func CreateOrGetWithRetry(ctx context.Context, clt client.Client, obj client.Object) error + func DefaultOptions() controller.Options + func DefaultRateLimiter() workqueue.RateLimiter + func DefaultTypedRateLimiter[T comparable]() workqueue.TypedRateLimiter[T] + func GetNumRequeues(ctx context.Context) int + func HasControllerReferenceByObjectReference(obj metav1.Object, ref *corev1.ObjectReference, controller bool) bool + func NewReconcilerWrapper(r reconcile.Reconciler, opts ...WrapperOption) reconcile.Reconciler + func RateLimiterCtx(ctx context.Context) workqueue.RateLimiter + func ReconcileRequestCtx(ctx context.Context) ctrl.Request + func TypedRateLimiter[T comparable](baseDelay time.Duration, maxDelay time.Duration) workqueue.TypedRateLimiter[T] + func WithNumRequeues(ctx context.Context, num int) context.Context + func WithRateLimiter(ctx context.Context, rl workqueue.RateLimiter) context.Context + func WithReconcileRequest(ctx context.Context, key ctrl.Request) context.Context + type AnnotationChangedPredicate struct + Keys []string + func (p AnnotationChangedPredicate) Create(e event.CreateEvent) bool + func (p AnnotationChangedPredicate) Delete(e event.DeleteEvent) bool + func (p AnnotationChangedPredicate) Generic(e event.GenericEvent) bool + func (p AnnotationChangedPredicate) Update(e event.UpdateEvent) bool + type BuilderOptionFunc func(options controller.Options) controller.Options + func MaxConCurrentReconciles(num int) BuilderOptionFunc + func RateLimiter(rl workqueue.TypedRateLimiter[reconcile.Request]) BuilderOptionFunc + type ControllerBuilderOption func(*builder.Builder) *builder.Builder + func WithBuilderOptions(opts controller.Options) ControllerBuilderOption + type ControllerChecker interface + type ControllerManager struct + func (m ControllerManager) GetEventRecorderFor(name string) cliengorecord.EventRecorder + type DependencyCheckerInterface interface + DependentCrdInstalled func(ctx context.Context, logger *zap.SugaredLogger) (bool, error) + type EventRecorder struct + MessageShortenLen int + func (recorder *EventRecorder) AnnotatedEventf(object runtime.Object, annotations map[string]string, ...) + func (recorder *EventRecorder) Event(object runtime.Object, eventtype, reason, message string) + func (recorder *EventRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, ...) + type Interface interface + Name func() string + Setup func(context.Context, manager.Manager, *zap.SugaredLogger) error + type LazyLoader interface + LazyLoad func(context.Context, manager.Manager, *zap.SugaredLogger, SetupChecker) error + Start func(context.Context) error + func NewLazyLoader(ctx context.Context, interval time.Duration) LazyLoader + type RequestFunc func(ctx context.Context, request reconcile.Request) (context.Context, error) + type ResultFunc func(ctx context.Context, request reconcile.Request, result *reconcile.Result) error + func SyncPeriodResultFunc(manager *config.Manager, configKey string) ResultFunc + type SecretDataChangedPredicate struct + func (SecretDataChangedPredicate) Update(e event.UpdateEvent) bool + type SetupChecker interface + CheckSetup func(context.Context, manager.Manager, *zap.SugaredLogger) error + type WrapperOption func(*WrapperOptions) + type WrapperOptions struct + Client client.Client + Object client.Object + RequestFuncs []RequestFunc + ResultFuncs []ResultFunc
Go to main page