uwcontroller

Documentation

Index

• type OptConfig
  • func WithControllerName(name string) OptConfig
  • func WithJitterPeriod(t time.Duration) OptConfig
  • func WithMaxConcurrentReconciles(n int) OptConfig
  • func WithOptions(o *Options) OptConfig
  • func WithReconciler(rc reconciler.UWReconciler) OptConfig
  • func WithWorkQueue(q workqueue.RateLimitingInterface) OptConfig
• type Options
• type UpwardController
  • func NewUWController(objectType client.Object, rc reconciler.UWReconciler, opts ...OptConfig) (*UpwardController, error)
  • func (c *UpwardController) AddToQueue(key string)
  • func (c *UpwardController) Start(stop <-chan struct{}) error

Types

type OptConfig

type OptConfig func(*Options)

func WithControllerName

func WithControllerName(name string) OptConfig

WithControllerName set the controller name.

func WithJitterPeriod

func WithJitterPeriod(t time.Duration) OptConfig

WithJitterPeriod set JitterPeriod.

func WithMaxConcurrentReconciles

func WithMaxConcurrentReconciles(n int) OptConfig

WithMaxConcurrentReconciles set MaxConcurrentReconciles if valid.

func WithOptions

func WithOptions(o *Options) OptConfig

WithOptions set options.

func WithReconciler

func WithReconciler(rc reconciler.UWReconciler) OptConfig

WithReconciler set the reconciler.

func WithWorkQueue

func WithWorkQueue(q workqueue.RateLimitingInterface) OptConfig

WithWorkQueue set the workqueue for mccontroller.

type Options

type Options struct {
	JitterPeriod time.Duration
	// MaxConcurrentReconciles is the number of concurrent control loops.
	MaxConcurrentReconciles int

	Reconciler reconciler.UWReconciler
	// Queue can be used to override the default queue.
	Queue workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

Options are the arguments for creating a new UpwardController.

type UpwardController

type UpwardController struct {
	Options
	// contains filtered or unexported fields
}

func NewUWController

func NewUWController(objectType client.Object, rc reconciler.UWReconciler, opts ...OptConfig) (*UpwardController, error)

func (*UpwardController) AddToQueue

func (c *UpwardController) AddToQueue(key string)

func (*UpwardController) Start

func (c *UpwardController) Start(stop <-chan struct{}) error