dynamic

Documentation

Index

• type Controller
  • func New(discovery discovery.DiscoveryInterface) *Controller
  • func (c *Controller) AddIndexer(name string, matcher GVKMatcher, ...)
  • func (c *Controller) Enqueue(gvk schema.GroupVersionKind, namespace, name string) error
  • func (c *Controller) EnqueueAfter(gvk schema.GroupVersionKind, namespace, name string, delay time.Duration) error
  • func (c *Controller) Get(gvk schema.GroupVersionKind, namespace, name string) (runtime.Object, error)
  • func (c *Controller) GetByIndex(gvk schema.GroupVersionKind, indexName, key string) ([]runtime.Object, error)
  • func (c *Controller) GetCache(_ context.Context, gvk schema.GroupVersionKind) (cache.SharedIndexInformer, bool, error)
  • func (c *Controller) List(gvk schema.GroupVersionKind, namespace string, selector labels.Selector) ([]runtime.Object, error)
  • func (c *Controller) OnChange(ctx context.Context, name string, matcher GVKMatcher, handler Handler)
  • func (c *Controller) OnGVKs(gvkList []schema.GroupVersionKind) error
  • func (c *Controller) Register(ctx context.Context, factory controller.SharedControllerFactory) error
  • func (c *Controller) Update(obj runtime.Object) (runtime.Object, error)
  • func (c *Controller) UpdateStatus(obj runtime.Object) (runtime.Object, error)
• type GVKMatcher
• type Handler
  • func FromKeyHandler(handler func(string, runtime.Object) (runtime.Object, error)) Handler

Types

type Controller

type Controller struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(discovery discovery.DiscoveryInterface) *Controller

func (*Controller) AddIndexer

func (c *Controller) AddIndexer(name string, matcher GVKMatcher, indexer func(obj runtime.Object) ([]string, error))

func (*Controller) Enqueue

func (c *Controller) Enqueue(gvk schema.GroupVersionKind, namespace, name string) error

func (*Controller) EnqueueAfter

func (c *Controller) EnqueueAfter(gvk schema.GroupVersionKind, namespace, name string, delay time.Duration) error

func (*Controller) Get

func (c *Controller) Get(gvk schema.GroupVersionKind, namespace, name string) (runtime.Object, error)

func (*Controller) GetByIndex

func (c *Controller) GetByIndex(gvk schema.GroupVersionKind, indexName, key string) ([]runtime.Object, error)

func (*Controller) GetCache

func (c *Controller) GetCache(_ context.Context, gvk schema.GroupVersionKind) (cache.SharedIndexInformer, bool, error)

func (*Controller) List

func (c *Controller) List(gvk schema.GroupVersionKind, namespace string, selector labels.Selector) ([]runtime.Object, error)

func (*Controller) OnChange

func (c *Controller) OnChange(ctx context.Context, name string, matcher GVKMatcher, handler Handler)

func (*Controller) OnGVKs

func (c *Controller) OnGVKs(gvkList []schema.GroupVersionKind) error

func (*Controller) Register

func (c *Controller) Register(ctx context.Context, factory controller.SharedControllerFactory) error

func (*Controller) Update

func (c *Controller) Update(obj runtime.Object) (runtime.Object, error)

func (*Controller) UpdateStatus

func (c *Controller) UpdateStatus(obj runtime.Object) (runtime.Object, error)

type GVKMatcher

type GVKMatcher func(gvk schema.GroupVersionKind) bool

type Handler

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

func FromKeyHandler

func FromKeyHandler(handler func(string, runtime.Object) (runtime.Object, error)) Handler