controller

Documentation

Index

• type Controller
  • func New(name string, mgr manager.Manager, opts Options) (Controller, error)
  • func NewUnmanaged(name string, mgr manager.Manager, opts Options) (Controller, error)
• type Options

Types

type Controller

type Controller interface {
	controller.Controller
	WatchTarget(src source.Source, hdl handler.EventHandler, prct ...predicate.Predicate) error
}

func New

func New(name string, mgr manager.Manager, opts Options) (Controller, error)

func NewUnmanaged

func NewUnmanaged(name string, mgr manager.Manager, opts Options) (Controller, error)

type Options

type Options struct {
	// MaxConcurrentReconciles is the maximum number of concurrent Reconciles which can be run. Defaults to 1.
	MaxConcurrentReconciles int

	// Reconciler reconciles an object
	Reconciler reconcile.Reconciler

	// RateLimiter is used to limit how frequently requests may be queued.
	// Defaults to MaxOfRateLimiter which has both overall and per-item rate limiting.
	// The overall is a token bucket and the per-item is exponential.
	RateLimiter ratelimiter.RateLimiter

	// LogConstructor is used to construct a logger used for this controller and passed
	// to each reconciliation via the context field.
	LogConstructor func(request *reconcile.Request) logr.Logger

	// CacheSyncTimeout refers to the time limit set to wait for syncing caches.
	// Defaults to 2 minutes if not set.
	CacheSyncTimeout time.Duration

	// RecoverPanic indicates whether the panic caused by reconcile should be recovered.
	RecoverPanic bool
}