controller

Documentation

Index

• type Config
  • func (c *Config) GetExecutorConfig() *worker.Config
  • func (c *Config) GetObjectsResyncInterval() time.Duration
  • func (c *Config) GetPoliciesResyncInterval() time.Duration
  • func (c *Config) GetReconcilerConfig() *worker.Config
  • func (c *Config) GetWorkerQueueRetries() int
• type Controller
  • func NewController(cfg *Config, l *zap.Logger, clock clock.WithTicker, k kubernetes.Interface, ...) *Controller
  • func (c *Controller) Notify() <-chan error
  • func (c *Controller) Start(interrupt <-chan struct{})
• type WorkItem
  • func (w *WorkItem) String() string

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 (c *Config) GetExecutorConfig() *worker.Config

func (*Config) GetObjectsResyncInterval

func (c *Config) GetObjectsResyncInterval() time.Duration

func (*Config) GetPoliciesResyncInterval

func (c *Config) GetPoliciesResyncInterval() time.Duration

func (*Config) GetReconcilerConfig

func (c *Config) GetReconcilerConfig() *worker.Config

func (*Config) GetWorkerQueueRetries

func (c *Config) GetWorkerQueueRetries() int

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{})

type WorkItem

type WorkItem struct {
	// contains filtered or unexported fields
}

func (*WorkItem) String

func (w *WorkItem) String() string