controllerruntime

Documentation

Index

• func FieldIndexName(field string) string
• func KeyToNamespacedKey(ns string, baseKey string) string
• func NewNewCacheFunc(cacheFactory lcache.SharedCacheFactory, dynamic *dynamic.Controller) cache.NewCacheFunc
• type Cache
  • func (c *Cache) Get(ctx context.Context, key client.ObjectKey, out client.Object, ...) error
  • func (c *Cache) GetInformer(ctx context.Context, obj client.Object, options ...cache.InformerGetOption) (cache.Informer, error)
  • func (c *Cache) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, ...) (cache.Informer, error)
  • func (c *Cache) IndexField(ctx context.Context, obj client.Object, field string, ...) error
  • func (c *Cache) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (c *Cache) Start(ctx context.Context) error
  • func (c *Cache) WaitForCacheSync(ctx context.Context) bool
• type CacheReader
  • func (c *CacheReader) Get(_ context.Context, key client.ObjectKey, out client.Object, ...) error
  • func (c *CacheReader) List(_ context.Context, out client.ObjectList, opts ...client.ListOption) error

Functions

func FieldIndexName

func FieldIndexName(field string) string

FieldIndexName constructs the name of the index over the given field, for use with an indexer.

func KeyToNamespacedKey

func KeyToNamespacedKey(ns string, baseKey string) string

KeyToNamespacedKey prefixes the given index key with a namespace for use in field selector indexes.

func NewNewCacheFunc

func NewNewCacheFunc(cacheFactory lcache.SharedCacheFactory, dynamic *dynamic.Controller) cache.NewCacheFunc

Types

type Cache

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

func (*Cache) Get

func (c *Cache) Get(ctx context.Context, key client.ObjectKey, out client.Object, opts ...client.GetOption) error

func (*Cache) GetInformer

func (c *Cache) GetInformer(ctx context.Context, obj client.Object, options ...cache.InformerGetOption) (cache.Informer, error)

func (*Cache) GetInformerForKind

func (c *Cache) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, options ...cache.InformerGetOption) (cache.Informer, error)

func (*Cache) IndexField

func (c *Cache) IndexField(ctx context.Context, obj client.Object, field string, extractValue client.IndexerFunc) error

func (*Cache) List

func (c *Cache) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*Cache) Start

func (c *Cache) Start(ctx context.Context) error

func (*Cache) WaitForCacheSync

func (c *Cache) WaitForCacheSync(ctx context.Context) bool

type CacheReader

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

CacheReader wraps a cache.Index to implement the client.CacheReader interface for a single type.

func (*CacheReader) Get

func (c *CacheReader) Get(_ context.Context, key client.ObjectKey, out client.Object, opts ...client.GetOption) error

Get checks the indexer for the object and writes a copy of it if found.

func (*CacheReader) List

func (c *CacheReader) List(_ context.Context, out client.ObjectList, opts ...client.ListOption) error

List lists items out of the indexer and writes them to out.