generic

Documentation

Index

• Variables
• func ToName(h interface{}) string
• type Controller
  • func NewController(gvk schema.GroupVersionKind, informer cache.SharedIndexInformer, ...) *Controller
  • func (c *Controller) Enqueue(namespace, name string)
  • func (c *Controller) EnqueueAfter(namespace, name string, duration time.Duration)
  • func (c *Controller) GroupVersionKind() schema.GroupVersionKind
  • func (c *Controller) Informer() cache.SharedIndexInformer
  • 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) Controllers() map[schema.GroupVersionKind]*Controller
  • func (g *ControllerManager) Enqueue(gvk schema.GroupVersionKind, informer cache.SharedIndexInformer, ...)
  • func (g *ControllerManager) EnqueueAfter(gvk schema.GroupVersionKind, informer cache.SharedIndexInformer, ...)
  • func (g *ControllerManager) EnsureStart(ctx context.Context, gvk schema.GroupVersionKind, threadiness int) error
  • func (g *ControllerManager) Start(ctx context.Context, defaultThreadiness int, ...) error
• type ControllerMeta
• type GeneratingHandlerOptions
• type Handler
  • func NewRemoveHandler(name string, updater Updater, handler Handler) Handler
• type HandlerTransaction
  • func NewHandlerTransaction(ctx context.Context) *HandlerTransaction
  • func (h *HandlerTransaction) Commit()
  • func (h *HandlerTransaction) Rollback()
• type Handlers
  • func (h *Handlers) Handle(key string, obj runtime.Object) (runtime.Object, error)
• type Updater

Variables

var ErrSkip = errors2.New("skip processing")

Functions

func ToName

func ToName(h interface{}) string

Types

type Controller

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

Controller is the controller implementation for Foo resources

func NewController

func NewController(gvk schema.GroupVersionKind, 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) EnqueueAfter

func (c *Controller) EnqueueAfter(namespace, name string, duration time.Duration)

func (*Controller) GroupVersionKind

func (c *Controller) GroupVersionKind() schema.GroupVersionKind

func (*Controller) Informer

func (c *Controller) Informer() cache.SharedIndexInformer

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) Controllers

func (g *ControllerManager) Controllers() map[schema.GroupVersionKind]*Controller

func (*ControllerManager) Enqueue

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

func (*ControllerManager) EnqueueAfter

func (g *ControllerManager) EnqueueAfter(gvk schema.GroupVersionKind, informer cache.SharedIndexInformer, namespace, name string, duration time.Duration)

func (*ControllerManager) EnsureStart

func (g *ControllerManager) EnsureStart(ctx context.Context, gvk schema.GroupVersionKind, threadiness int) error

func (*ControllerManager) Start

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

type ControllerMeta

type ControllerMeta interface {
	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler Handler)
	Updater() Updater
}

type GeneratingHandlerOptions

type GeneratingHandlerOptions struct {
	AllowCrossNamespace bool
	AllowClusterScoped  bool
	DynamicLookup       bool
}

type Handler

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

func NewRemoveHandler

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

type HandlerTransaction

type HandlerTransaction struct {
	context.Context
	// contains filtered or unexported fields
}

func NewHandlerTransaction

func NewHandlerTransaction(ctx context.Context) *HandlerTransaction

func (*HandlerTransaction) Commit

func (h *HandlerTransaction) Commit()

func (*HandlerTransaction) Rollback

func (h *HandlerTransaction) Rollback()

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)