store

Documentation

Index

• func GetAs(ctx context.Context, o Store, key Key, as runtime.Object) (bool, error)
• type Key
  • func KeyFromGroupVersionKind(groupVersionKind schema.GroupVersionKind) Key
  • func KeyFromObject(object runtime.Object) (Key, error)
  • func KeyFromPayload(payload action.Payload) (Key, error)
  • func (k Key) GroupVersionKind() schema.GroupVersionKind
  • func (k Key) String() string
  • func (k Key) ToActionPayload() action.Payload
• type Store
• type UpdateFn

Functions

func GetAs

func GetAs(ctx context.Context, o Store, key Key, as runtime.Object) (bool, error)

GetAs gets an object from the object store by key. If the object is not found, return false and a nil error.

Types

type Key

type Key struct {
	Namespace  string      `json:"namespace"`
	APIVersion string      `json:"apiVersion"`
	Kind       string      `json:"kind"`
	Name       string      `json:"name"`
	Selector   *labels.Set `json:"selector"`
}

Key is a key for the object store.

func KeyFromGroupVersionKind

func KeyFromGroupVersionKind(groupVersionKind schema.GroupVersionKind) Key

KeyFromGroupVersionKind creates a key from a group version kind.

func KeyFromObject

func KeyFromObject(object runtime.Object) (Key, error)

KeyFromObject creates a key from a runtime object.

func KeyFromPayload

func KeyFromPayload(payload action.Payload) (Key, error)

KeyFromPayload converts a payload into a Key.

func (Key) GroupVersionKind

func (k Key) GroupVersionKind() schema.GroupVersionKind

GroupVersionKind converts the Key to a GroupVersionKind.

func (Key) String

func (k Key) String() string

func (Key) ToActionPayload

func (k Key) ToActionPayload() action.Payload

ToActionPayload converts the Key to a payload.

type Store

type Store interface {
	List(ctx context.Context, key Key) (list *unstructured.UnstructuredList, loading bool, err error)
	Get(ctx context.Context, key Key) (object *unstructured.Unstructured, err error)
	Delete(ctx context.Context, key Key) error
	Watch(ctx context.Context, key Key, handler cache.ResourceEventHandler) error
	Unwatch(ctx context.Context, groupVersionKinds ...schema.GroupVersionKind) error
	UpdateClusterClient(ctx context.Context, client cluster.ClientInterface) error
	RegisterOnUpdate(fn UpdateFn)
	Update(ctx context.Context, key Key, updater func(*unstructured.Unstructured) error) error
	IsLoading(ctx context.Context, key Key) bool
	Create(ctx context.Context, object *unstructured.Unstructured) error
}

Store stores Kubernetes objects.

type UpdateFn

type UpdateFn func(store Store)

UpdateFn is a function that is called when