objectstore

Documentation

Index

• func CreateOrUpdateFromHandler(ctx context.Context, namespace, input string, ...) ([]string, error)
• type DynamicCache
  • func NewDynamicCache(ctx context.Context, client cluster.ClientInterface, opts ...Option) (*DynamicCache, error)
  • func (d *DynamicCache) CheckResourceAccess(ctx context.Context, gvr schema.GroupVersionResource) bool
  • func (d *DynamicCache) Create(ctx context.Context, object *unstructured.Unstructured) error
  • func (d *DynamicCache) CreateOrUpdateFromYAML(ctx context.Context, namespace, input string) ([]string, error)
  • func (d *DynamicCache) Delete(ctx context.Context, key store.Key) error
  • func (d *DynamicCache) Get(ctx context.Context, key store.Key) (object *unstructured.Unstructured, err error)
  • func (d *DynamicCache) IsLoading(ctx context.Context, key store.Key) bool
  • func (d *DynamicCache) List(ctx context.Context, key store.Key) (list *unstructured.UnstructuredList, loading bool, err error)
  • func (d *DynamicCache) Unwatch(ctx context.Context, groupVersionKinds ...schema.GroupVersionKind) error
  • func (d *DynamicCache) Update(ctx context.Context, key store.Key, ...) error
  • func (d *DynamicCache) UpdateClusterClient(ctx context.Context, client cluster.ClientInterface) error
  • func (d *DynamicCache) WaitForCacheSync(ctx context.Context) bool
  • func (d *DynamicCache) Watch(ctx context.Context, key store.Key, handler cache.ResourceEventHandler) error
• type Option
  • func WithDynamicSharedInformerFactory(factory dynamicinformer.DynamicSharedInformerFactory) Option

Functions

func CreateOrUpdateFromHandler

func CreateOrUpdateFromHandler(
	ctx context.Context, namespace, input string,
	get func(context.Context, store.Key) (*unstructured.Unstructured, error),
	create func(context.Context, *unstructured.Unstructured) error,
	clusterClient cluster.ClientInterface,
) ([]string, error)

Types

type DynamicCache

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

func NewDynamicCache

func NewDynamicCache(ctx context.Context, client cluster.ClientInterface, opts ...Option) (*DynamicCache, error)

func (*DynamicCache) CheckResourceAccess

func (d *DynamicCache) CheckResourceAccess(ctx context.Context, gvr schema.GroupVersionResource) bool

func (*DynamicCache) Create

func (d *DynamicCache) Create(ctx context.Context, object *unstructured.Unstructured) error

func (*DynamicCache) CreateOrUpdateFromYAML

func (d *DynamicCache) CreateOrUpdateFromYAML(ctx context.Context, namespace, input string) ([]string, error)

CreateOrUpdateFromYAML creates resources in the cluster from YAML input. Resources are created in the order they are present in the YAML. An error creating a resource halts resource creation. A list of created resources is returned. You may have created resources AND a non-nil error.

func (*DynamicCache) Delete

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

func (*DynamicCache) Get

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

func (*DynamicCache) IsLoading

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

func (*DynamicCache) List

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

func (*DynamicCache) Unwatch

func (d *DynamicCache) Unwatch(ctx context.Context, groupVersionKinds ...schema.GroupVersionKind) error

func (*DynamicCache) Update

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

func (*DynamicCache) UpdateClusterClient

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

func (*DynamicCache) WaitForCacheSync

func (d *DynamicCache) WaitForCacheSync(ctx context.Context) bool

func (*DynamicCache) Watch

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

type Option

type Option func(*DynamicCache)

func WithDynamicSharedInformerFactory

func WithDynamicSharedInformerFactory(factory dynamicinformer.DynamicSharedInformerFactory) Option