v1

Documentation

Index

• func FromStorageClassHandlerToHandler(sync StorageClassHandler) generic.Handler
• type Interface
  • func New(controllerManager *generic.ControllerManager, ...) Interface
• type StorageClassCache
• type StorageClassClient
• type StorageClassController
  • func NewStorageClassController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) StorageClassController
• type StorageClassHandler
  • func UpdateStorageClassOnChange(updater generic.Updater, handler StorageClassHandler) StorageClassHandler
• type StorageClassIndexer

Functions

func FromStorageClassHandlerToHandler

func FromStorageClassHandlerToHandler(sync StorageClassHandler) generic.Handler

Types

type Interface

type Interface interface {
	StorageClass() StorageClassController
}

func New

func New(controllerManager *generic.ControllerManager, client clientset.StorageV1Interface,
	informers informers.Interface) Interface

type StorageClassCache

type StorageClassCache interface {
	Get(name string) (*v1.StorageClass, error)
	List(selector labels.Selector) ([]*v1.StorageClass, error)

	AddIndexer(indexName string, indexer StorageClassIndexer)
	GetByIndex(indexName, key string) ([]*v1.StorageClass, error)
}

type StorageClassClient

type StorageClassClient interface {
	Create(*v1.StorageClass) (*v1.StorageClass, error)
	Update(*v1.StorageClass) (*v1.StorageClass, error)

	Delete(name string, options *metav1.DeleteOptions) error
	Get(name string, options metav1.GetOptions) (*v1.StorageClass, error)
	List(opts metav1.ListOptions) (*v1.StorageClassList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
	Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.StorageClass, err error)
}

type StorageClassController

type StorageClassController interface {
	StorageClassClient

	OnChange(ctx context.Context, name string, sync StorageClassHandler)
	OnRemove(ctx context.Context, name string, sync StorageClassHandler)
	Enqueue(name string)

	Cache() StorageClassCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewStorageClassController

func NewStorageClassController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.StorageClassesGetter, informer informers.StorageClassInformer) StorageClassController

type StorageClassHandler

type StorageClassHandler func(string, *v1.StorageClass) (*v1.StorageClass, error)

func UpdateStorageClassOnChange

func UpdateStorageClassOnChange(updater generic.Updater, handler StorageClassHandler) StorageClassHandler

type StorageClassIndexer

type StorageClassIndexer func(obj *v1.StorageClass) ([]string, error)