v1

package
v0.0.2-pre Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 23, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromPersistentVolumeHandlerToHandler

func FromPersistentVolumeHandlerToHandler(sync PersistentVolumeHandler) generic.Handler

func RegisterPersistentVolumeGeneratingHandler

func RegisterPersistentVolumeGeneratingHandler(ctx context.Context, controller PersistentVolumeController, apply apply.Apply,
	condition condition.Cond, name string, handler PersistentVolumeGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterPersistentVolumeStatusHandler

func RegisterPersistentVolumeStatusHandler(ctx context.Context, controller PersistentVolumeController, condition condition.Cond, name string, handler PersistentVolumeStatusHandler)

func UpdatePersistentVolumeDeepCopyOnChange

func UpdatePersistentVolumeDeepCopyOnChange(client PersistentVolumeClient, obj *v1.PersistentVolume, handler func(obj *v1.PersistentVolume) (*v1.PersistentVolume, error)) (*v1.PersistentVolume, error)

Types

type Interface

type Interface interface {
	PersistentVolume() PersistentVolumeController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type PersistentVolumeCache

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

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

type PersistentVolumeClient

type PersistentVolumeClient interface {
	Create(*v1.PersistentVolume) (*v1.PersistentVolume, error)
	Update(*v1.PersistentVolume) (*v1.PersistentVolume, error)
	UpdateStatus(*v1.PersistentVolume) (*v1.PersistentVolume, error)
	Delete(name string, options *metav1.DeleteOptions) error
	Get(name string, options metav1.GetOptions) (*v1.PersistentVolume, error)
	List(opts metav1.ListOptions) (*v1.PersistentVolumeList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
	Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.PersistentVolume, err error)
}

type PersistentVolumeController

type PersistentVolumeController interface {
	generic.ControllerMeta
	PersistentVolumeClient

	OnChange(ctx context.Context, name string, sync PersistentVolumeHandler)
	OnRemove(ctx context.Context, name string, sync PersistentVolumeHandler)
	Enqueue(name string)
	EnqueueAfter(name string, duration time.Duration)

	Cache() PersistentVolumeCache
}

func NewPersistentVolumeController

func NewPersistentVolumeController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) PersistentVolumeController

type PersistentVolumeGeneratingHandler

type PersistentVolumeGeneratingHandler func(obj *v1.PersistentVolume, status v1.PersistentVolumeStatus) ([]runtime.Object, v1.PersistentVolumeStatus, error)

type PersistentVolumeHandler

type PersistentVolumeHandler func(string, *v1.PersistentVolume) (*v1.PersistentVolume, error)

type PersistentVolumeIndexer

type PersistentVolumeIndexer func(obj *v1.PersistentVolume) ([]string, error)

type PersistentVolumeStatusHandler

type PersistentVolumeStatusHandler func(obj *v1.PersistentVolume, status v1.PersistentVolumeStatus) (v1.PersistentVolumeStatus, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL