v3

package
v0.1.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromClusterRegistrationTokenHandlerToHandler

func FromClusterRegistrationTokenHandlerToHandler(sync ClusterRegistrationTokenHandler) generic.Handler

func FromSettingHandlerToHandler

func FromSettingHandlerToHandler(sync SettingHandler) generic.Handler

func RegisterClusterRegistrationTokenStatusHandler

func RegisterClusterRegistrationTokenStatusHandler(ctx context.Context, controller ClusterRegistrationTokenController, condition condition.Cond, name string, handler ClusterRegistrationTokenStatusHandler)

func UpdateSettingDeepCopyOnChange

func UpdateSettingDeepCopyOnChange(client SettingClient, obj *v3.Setting, handler func(obj *v3.Setting) (*v3.Setting, error)) (*v3.Setting, error)

Types

type ClusterRegistrationTokenCache

type ClusterRegistrationTokenCache interface {
	Get(namespace, name string) (*v3.ClusterRegistrationToken, error)
	List(namespace string, selector labels.Selector) ([]*v3.ClusterRegistrationToken, error)

	AddIndexer(indexName string, indexer ClusterRegistrationTokenIndexer)
	GetByIndex(indexName, key string) ([]*v3.ClusterRegistrationToken, error)
}

type ClusterRegistrationTokenClient

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

type ClusterRegistrationTokenController

type ClusterRegistrationTokenController interface {
	generic.ControllerMeta
	ClusterRegistrationTokenClient

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

	Cache() ClusterRegistrationTokenCache
}

func NewClusterRegistrationTokenController

func NewClusterRegistrationTokenController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ClusterRegistrationTokenController

type ClusterRegistrationTokenIndexer

type ClusterRegistrationTokenIndexer func(obj *v3.ClusterRegistrationToken) ([]string, error)

type Interface

type Interface interface {
	ClusterRegistrationToken() ClusterRegistrationTokenController
	Setting() SettingController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type SettingCache

type SettingCache interface {
	Get(name string) (*v3.Setting, error)
	List(selector labels.Selector) ([]*v3.Setting, error)

	AddIndexer(indexName string, indexer SettingIndexer)
	GetByIndex(indexName, key string) ([]*v3.Setting, error)
}

type SettingClient

type SettingClient interface {
	Create(*v3.Setting) (*v3.Setting, error)
	Update(*v3.Setting) (*v3.Setting, error)

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

type SettingController

type SettingController interface {
	generic.ControllerMeta
	SettingClient

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

	Cache() SettingCache
}

func NewSettingController

func NewSettingController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) SettingController

type SettingHandler

type SettingHandler func(string, *v3.Setting) (*v3.Setting, error)

type SettingIndexer

type SettingIndexer func(obj *v3.Setting) ([]string, error)

Jump to

Keyboard shortcuts

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