controller

type Controller struct {
	// Name is used to uniquely identify a Controller in tracing, logging and monitoring. Name is required.
	Name string

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

	// Reconciler is a function that can be called at any time with the ID of an object and
	// ensures that the state of the system matches the state specified in the object.
	Do v1.Reconciler

	// CacheSyncTimeout refers to the time limit set on waiting for cache to sync
	// Defaults to 2 minutes if not set.
	CacheSyncTimeout time.Duration

	// PollJitter defines how much polling jitter should there be when polling for new resources.
	PollJitter time.Duration

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

	DeQueueJitter time.Duration
	// contains filtered or unexported fields
}

type ControllerManagerOption func(*Manager) error

type Manager struct {
	sync.Mutex

	Controllers []*Controller

	// MaxConcurrentReconciles is the maximum number of concurrent Reconciles which can be run.
	MaxConcurrentReconciles int

	// CacheSyncTimeout refers to the time limit set on waiting for cache to sync
	// Defaults to 2 minutes if not set.
	CacheSyncTimeout time.Duration

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

	// PollInterval defines how often controllers should poll for new resources.
	PollInterval time.Duration

	// PollJitter defines how much polling jitter should there be when polling for new resources.
	PollJitter time.Duration

	// LivenessCheckInterval recheck the controller liveness.
	LivenessCheckInterval time.Duration

	Socket websocket.Socket
	// contains filtered or unexported fields
}