controller

Documentation

Overview

Package controller provides utilties for working with controllers.

Index

• Variables
• type Engine
  • func NewEngine(mgr manager.Manager, o ...EngineOption) *Engine
  • func (e *Engine) Err(name string) error
  • func (e *Engine) IsRunning(name string) bool
  • func (e *Engine) Start(name string, o controller.Options, w ...Watch) error
  • func (e *Engine) Stop(name string)
• type EngineOption
  • func WithNewCacheFn(fn NewCacheFn) EngineOption
  • func WithNewControllerFn(fn NewControllerFn) EngineOption
• type NewCacheFn
• type NewControllerFn
• type Watch
  • func For(kind client.Object, h handler.EventHandler, p ...predicate.Predicate) Watch

Variables

var (
	DefaultNewCacheFn      NewCacheFn      = cache.New
	DefaultNewControllerFn NewControllerFn = controller.NewUnmanaged
)

The default new cache and new controller functions.

Types

type Engine

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

An Engine manages the lifecycles of controller-runtime controllers (and their caches). The lifecycles of the controllers are not coupled to lifecycle of the engine, nor to the lifecycle of the controller manager it uses.

func NewEngine

func NewEngine(mgr manager.Manager, o ...EngineOption) *Engine

NewEngine produces a new Engine.

func (*Engine) Err

func (e *Engine) Err(name string) error

Err returns any error encountered by the named controller. The returned error is always nil if the named controller is running.

func (*Engine) IsRunning

func (e *Engine) IsRunning(name string) bool

IsRunning indicates whether the named controller is running - i.e. whether it has been started and does not appear to have crashed.

func (*Engine) Start

func (e *Engine) Start(name string, o controller.Options, w ...Watch) error

Start the named controller. Each controller is started with its own cache whose lifecycle is coupled to the controller. The controller is started with the supplied options, and configured with the supplied watches. Start does not block.

func (*Engine) Stop

func (e *Engine) Stop(name string)

Stop the named controller.

type EngineOption

type EngineOption func(*Engine)

An EngineOption configures an Engine.

func WithNewCacheFn

func WithNewCacheFn(fn NewCacheFn) EngineOption

WithNewCacheFn may be used to configure a different cache implementation. DefaultNewCacheFn is used by default.

func WithNewControllerFn

func WithNewControllerFn(fn NewControllerFn) EngineOption

WithNewControllerFn may be used to configure a different controller implementation. DefaultNewControllerFn is used by default.

type NewCacheFn

type NewCacheFn func(cfg *rest.Config, o cache.Options) (cache.Cache, error)

A NewCacheFn creates a new controller-runtime cache.

type NewControllerFn

type NewControllerFn func(name string, m manager.Manager, o controller.Options) (controller.Controller, error)

A NewControllerFn creates a new controller-runtime controller.

type Watch

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

Watch an object.

func For

func For(kind client.Object, h handler.EventHandler, p ...predicate.Predicate) Watch

For returns a Watch for the supplied kind of object. Events will be handled by the supplied EventHandler, and may be filtered by the supplied predicates.