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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OptConfig ¶
type OptConfig func(*Options)
func WithControllerName ¶
WithControllerName set the controller name.
func WithJitterPeriod ¶
WithJitterPeriod set JitterPeriod.
func WithMaxConcurrentReconciles ¶
WithMaxConcurrentReconciles set MaxConcurrentReconciles if valid.
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
Source Files
Click to show internal directories.
Click to hide internal directories.