objectstore

Documentation

Index

• type AccessError
  • func (ae *AccessError) Error() string
• type AccessKey
• type DynamicCache
  • func NewDynamicCache(ctx context.Context, client cluster.ClientInterface, ...) (*DynamicCache, error)
  • func (dc *DynamicCache) Delete(ctx context.Context, key store.Key) error
  • func (dc *DynamicCache) Get(ctx context.Context, key store.Key) (object *unstructured.Unstructured, found bool, err error)
  • func (dc *DynamicCache) IsLoading(ctx context.Context, key store.Key) bool
  • func (dc *DynamicCache) List(ctx context.Context, key store.Key) (list *unstructured.UnstructuredList, loading bool, err error)
  • func (dc *DynamicCache) RegisterOnUpdate(fn store.UpdateFn)
  • func (dc *DynamicCache) Unwatch(ctx context.Context, gvk ...schema.GroupVersionKind) error
  • func (dc *DynamicCache) Update(ctx context.Context, key store.Key, ...) error
  • func (dc *DynamicCache) UpdateClusterClient(ctx context.Context, client cluster.ClientInterface) error
  • func (dc *DynamicCache) Watch(ctx context.Context, key store.Key, handler kcache.ResourceEventHandler) error
• type DynamicCacheOpt
  • func Access(resourceAccess ResourceAccess) DynamicCacheOpt
• type InformerFactory
• type ResourceAccess
  • func NewResourceAccess(client cluster.ClientInterface) ResourceAccess

Types

type AccessError

type AccessError struct {
	Key AccessKey
}

func (*AccessError) Error

func (ae *AccessError) Error() string

type AccessKey

type AccessKey struct {
	Namespace string
	Group     string
	Resource  string
	Verb      string
}

AccessKey is used at a key in an access map, It is made up of a namespace, Group, Resource and Verb.

type DynamicCache

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

func NewDynamicCache

func NewDynamicCache(ctx context.Context, client cluster.ClientInterface, options ...DynamicCacheOpt) (*DynamicCache, error)

NewDynamicCache creates an instance of DynamicCache.

func (*DynamicCache) Delete

func (dc *DynamicCache) Delete(ctx context.Context, key store.Key) error

func (*DynamicCache) Get

func (dc *DynamicCache) Get(ctx context.Context, key store.Key) (object *unstructured.Unstructured, found bool, err error)

func (*DynamicCache) IsLoading

func (dc *DynamicCache) IsLoading(ctx context.Context, key store.Key) bool

func (*DynamicCache) List

func (dc *DynamicCache) List(ctx context.Context, key store.Key) (list *unstructured.UnstructuredList, loading bool, err error)

func (*DynamicCache) RegisterOnUpdate

func (dc *DynamicCache) RegisterOnUpdate(fn store.UpdateFn)

RegisterOnUpdate registers a function that will be called when the store updates it's client. TODO: investigate if this needed since object store isn't replaced, it's client is.

func (*DynamicCache) Unwatch

func (dc *DynamicCache) Unwatch(ctx context.Context, gvk ...schema.GroupVersionKind) error

func (*DynamicCache) Update

func (dc *DynamicCache) Update(ctx context.Context, key store.Key, updater func(*unstructured.Unstructured) error) error

func (*DynamicCache) UpdateClusterClient

func (dc *DynamicCache) UpdateClusterClient(ctx context.Context, client cluster.ClientInterface) error

func (*DynamicCache) Watch

func (dc *DynamicCache) Watch(ctx context.Context, key store.Key, handler kcache.ResourceEventHandler) error

Watch watches the cluster for an event and performs actions with the supplied handler.

type DynamicCacheOpt

type DynamicCacheOpt func(*DynamicCache)

func Access

func Access(resourceAccess ResourceAccess) DynamicCacheOpt

Access sets the Resource Access cache for a DynamicCache.

type InformerFactory

type InformerFactory interface {
	ForResource(gvr schema.GroupVersionResource) informers.GenericInformer
	Delete(gvr schema.GroupVersionResource)
	WaitForCacheSync(stopCh <-chan struct{}) map[schema.GroupVersionResource]bool
}

InformerFactory creates informers.

type ResourceAccess

type ResourceAccess interface {
	HasAccess(ctx context.Context, key store.Key, verb string) error
	Reset()
	Get(key AccessKey) (bool, bool)
	Set(key AccessKey, value bool)
	UpdateClient(client cluster.ClientInterface)
}

func NewResourceAccess

func NewResourceAccess(client cluster.ClientInterface) ResourceAccess