controller

Jul 14, 2023

Changes in this version

+ func GetConcurrent(opts RateLimiterOptions) int

Jul 13, 2023

Changes in this version

+ var WaitDelete = fmt.Errorf("wait delete resource")

+ func DefaultFunc(ctx context.Context, obj client.Object) error

+ func GetRateLimiter(opts RateLimiterOptions) ratelimiter.RateLimiter

+ type Controller struct

+ Eventer record.EventRecorder

+ FinalizerName string

+ Gvk schema.GroupVersionKind

+ Logger logr.Logger

+ Operator Operator

+ func (r *Controller) GroupVersionKind() schema.GroupVersionKind

+ func (r *Controller) Run(ctx context.Context, req ctrl.Request, obj client.Object) (ctrl.Result, error)

+ type Finalizer struct

+ func NewFinalizer(client client.Client, finalizerName string) *Finalizer

+ func (f *Finalizer) AddFinalizer(ctx context.Context, obj client.Object) (bool, error)

+ func (f *Finalizer) RemoveFinalizer(ctx context.Context, obj client.Object, ...) (bool, error)

+ type Operator interface

+ Delete func(ctx context.Context, req ctrl.Request, gvk schema.GroupVersionKind, ...) error

+ Update func(ctx context.Context, req ctrl.Request, gvk schema.GroupVersionKind, ...) (ctrl.Result, error)

+ type RateLimiterOptions struct

+ Burst int

+ MaxRetryDelay time.Duration

+ MinRetryDelay time.Duration

+ QPS float64

+ func (o *RateLimiterOptions) BindFlags(fs *flag.FlagSet)