controller

Documentation

Index

• Variables
• func DefaultFunc(ctx context.Context, obj client.Object) error
• func GetRateLimiter(opts RateLimiterOptions) ratelimiter.RateLimiter
• type Controller
  • func (r *Controller) GroupVersionKind() schema.GroupVersionKind
  • func (r *Controller) Run(ctx context.Context, req ctrl.Request, obj client.Object) (ctrl.Result, error)
• type Finalizer
  • 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
• type RateLimiterOptions
  • func (o *RateLimiterOptions) BindFlags(fs *flag.FlagSet)

Variables

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

Functions

func DefaultFunc

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

func GetRateLimiter

func GetRateLimiter(opts RateLimiterOptions) ratelimiter.RateLimiter

Types

type Controller

type Controller struct {
	client.Client
	Eventer       record.EventRecorder
	Operator      Operator
	Gvk           schema.GroupVersionKind
	Logger        logr.Logger
	FinalizerName string
}

func (*Controller) GroupVersionKind

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

func (*Controller) Run

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

type Finalizer

type Finalizer struct {
	// contains filtered or unexported fields
}

func NewFinalizer

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

func (*Finalizer) AddFinalizer

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

func (*Finalizer) RemoveFinalizer

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

type Operator

type Operator interface {
	Update(ctx context.Context, req ctrl.Request, gvk schema.GroupVersionKind, obj client.Object) (ctrl.Result, error)
	Delete(ctx context.Context, req ctrl.Request, gvk schema.GroupVersionKind, obj client.Object) error
}

type RateLimiterOptions

type RateLimiterOptions struct {
	MinRetryDelay time.Duration
	QPS           float64
	Burst         int
	MaxRetryDelay time.Duration
}

RateLimiterOptions used on reconcilers.

func (*RateLimiterOptions) BindFlags

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