generic

Documentation

Index

• type Controller
  • func NewController(name string, informer cache.SharedIndexInformer, ...) *Controller
  • func (c *Controller) Enqueue(namespace, name string)
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error
• type ControllerManager
  • func (g *ControllerManager) AddHandler(ctx context.Context, gvk schema.GroupVersionKind, ...)
  • func (g *ControllerManager) Enqueue(gvk schema.GroupVersionKind, namespace, name string)
  • func (g *ControllerManager) Start(ctx context.Context, defaultThreadiness int, ...) error
• type Handler
  • func NewRemoveHandler(name string, updater Updater, handler Handler) Handler
  • func UpdateOnChange(updater Updater, handler Handler) Handler
• type Handlers
  • func (h *Handlers) Handle(key string, obj runtime.Object) (runtime.Object, error)
• type Updater

Types

type Controller

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

Controller is the controller implementation for Foo resources

func NewController

func NewController(name string, informer cache.SharedIndexInformer, workqueue workqueue.RateLimitingInterface, handler Handler) *Controller

NewController returns a new sample controller

func (*Controller) Enqueue

func (c *Controller) Enqueue(namespace, name string)

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

type ControllerManager

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

func (*ControllerManager) AddHandler

func (g *ControllerManager) AddHandler(ctx context.Context, gvk schema.GroupVersionKind, informer cache.SharedIndexInformer, name string, handler Handler)

func (*ControllerManager) Enqueue

func (g *ControllerManager) Enqueue(gvk schema.GroupVersionKind, namespace, name string)

func (*ControllerManager) Start

func (g *ControllerManager) Start(ctx context.Context, defaultThreadiness int, threadiness map[schema.GroupVersionKind]int) error

type Handler

type Handler func(key string, obj runtime.Object) (runtime.Object, error)

func NewRemoveHandler

func NewRemoveHandler(name string, updater Updater, handler Handler) Handler

func UpdateOnChange

func UpdateOnChange(updater Updater, handler Handler) Handler

type Handlers

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

func (*Handlers) Handle

func (h *Handlers) Handle(key string, obj runtime.Object) (runtime.Object, error)

type Updater

type Updater func(runtime.Object) (runtime.Object, error)