Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { ObjectsResyncSeconds int `json:"core_resync_seconds" env:"CONTROLLER_OBJECTS_RESYNC_SECONDS"` PoliciesResyncSeconds int `json:"policies_resync_seconds" env:"CONTROLLER_POLICIES_RESYNC_SECONDS"` ReconcilerThreadiness int `json:"reconciler_threadiness" env:"CONTROLLER_RECONCILER_THREADINESS"` ExecutorThreadiness int `json:"executor_threadiness" env:"CONTROLLER_EXECUTOR_THREADINESS"` WorkerQueueRetries int `json:"worker_queue_retries" env:"CONTROLLER_WORKER_QUEUE_RETRIES"` }
func (*Config) GetExecutorConfig ¶
func (*Config) GetObjectsResyncInterval ¶
func (*Config) GetPoliciesResyncInterval ¶
func (*Config) GetReconcilerConfig ¶
func (*Config) GetWorkerQueueRetries ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController( cfg *Config, l *zap.Logger, clock clock.WithTicker, k kubernetes.Interface, az azure.Interface, ) *Controller
func (*Controller) Notify ¶
func (c *Controller) Notify() <-chan error
func (*Controller) Start ¶
func (c *Controller) Start(interrupt <-chan struct{})
Click to show internal directories.
Click to hide internal directories.