v1

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Sep 8, 2023 License: Apache-2.0 Imports: 20 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromPersistentVolumeHandlerToHandler 

func FromPersistentVolumeHandlerToHandler(sync PersistentVolumeHandler) generic.Handler

func FromResourceQuotaHandlerToHandler added in v1.2.0 

func FromResourceQuotaHandlerToHandler(sync ResourceQuotaHandler) 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 RegisterResourceQuotaGeneratingHandler added in v1.2.0 

func RegisterResourceQuotaGeneratingHandler(ctx context.Context, controller ResourceQuotaController, apply apply.Apply,
	condition condition.Cond, name string, handler ResourceQuotaGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterResourceQuotaStatusHandler added in v1.2.0 

func RegisterResourceQuotaStatusHandler(ctx context.Context, controller ResourceQuotaController, condition condition.Cond, name string, handler ResourceQuotaStatusHandler)

func UpdatePersistentVolumeDeepCopyOnChange 

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

func UpdateResourceQuotaDeepCopyOnChange added in v1.2.0 

func UpdateResourceQuotaDeepCopyOnChange(client ResourceQuotaClient, obj *v1.ResourceQuota, handler func(obj *v1.ResourceQuota) (*v1.ResourceQuota, error)) (*v1.ResourceQuota, error)

Types

type Interface 

type Interface interface {
	PersistentVolume() PersistentVolumeController
	ResourceQuota() ResourceQuotaController
}

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)

type ResourceQuotaCache added in v1.2.0 

type ResourceQuotaCache interface {
	Get(namespace, name string) (*v1.ResourceQuota, error)
	List(namespace string, selector labels.Selector) ([]*v1.ResourceQuota, error)

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

type ResourceQuotaClient added in v1.2.0 

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

type ResourceQuotaController added in v1.2.0 

type ResourceQuotaController interface {
	generic.ControllerMeta
	ResourceQuotaClient

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

	Cache() ResourceQuotaCache
}

func NewResourceQuotaController added in v1.2.0 

func NewResourceQuotaController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ResourceQuotaController

type ResourceQuotaGeneratingHandler added in v1.2.0 

type ResourceQuotaGeneratingHandler func(obj *v1.ResourceQuota, status v1.ResourceQuotaStatus) ([]runtime.Object, v1.ResourceQuotaStatus, error)

type ResourceQuotaHandler added in v1.2.0 

type ResourceQuotaHandler func(string, *v1.ResourceQuota) (*v1.ResourceQuota, error)

type ResourceQuotaIndexer added in v1.2.0 

type ResourceQuotaIndexer func(obj *v1.ResourceQuota) ([]string, error)

type ResourceQuotaStatusHandler added in v1.2.0 

type ResourceQuotaStatusHandler func(obj *v1.ResourceQuota, status v1.ResourceQuotaStatus) (v1.ResourceQuotaStatus, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.