v1alpha1

package
Version: v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Jan 25, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromKubeconfigHandlerToHandler

func FromKubeconfigHandlerToHandler(sync KubeconfigHandler) generic.Handler

func FromUserHandlerToHandler

func FromUserHandlerToHandler(sync UserHandler) generic.Handler

func RegisterUserGeneratingHandler

func RegisterUserGeneratingHandler(ctx context.Context, controller UserController, apply apply.Apply,
	condition condition.Cond, name string, handler UserGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterUserStatusHandler

func RegisterUserStatusHandler(ctx context.Context, controller UserController, condition condition.Cond, name string, handler UserStatusHandler)

func UpdateKubeconfigDeepCopyOnChange

func UpdateKubeconfigDeepCopyOnChange(client KubeconfigClient, obj *v1alpha1.Kubeconfig, handler func(obj *v1alpha1.Kubeconfig) (*v1alpha1.Kubeconfig, error)) (*v1alpha1.Kubeconfig, error)

func UpdateUserDeepCopyOnChange

func UpdateUserDeepCopyOnChange(client UserClient, obj *v1alpha1.User, handler func(obj *v1alpha1.User) (*v1alpha1.User, error)) (*v1alpha1.User, error)

Types

type Interface

type Interface interface {
	Kubeconfig() KubeconfigController
	User() UserController
}

func New

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

type KubeconfigCache

type KubeconfigCache interface {
	Get(name string) (*v1alpha1.Kubeconfig, error)
	List(selector labels.Selector) ([]*v1alpha1.Kubeconfig, error)

	AddIndexer(indexName string, indexer KubeconfigIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha1.Kubeconfig, error)
}

type KubeconfigClient

type KubeconfigClient interface {
	Create(*v1alpha1.Kubeconfig) (*v1alpha1.Kubeconfig, error)
	Update(*v1alpha1.Kubeconfig) (*v1alpha1.Kubeconfig, error)

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

type KubeconfigController

type KubeconfigController interface {
	generic.ControllerMeta
	KubeconfigClient

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

	Cache() KubeconfigCache
}

type KubeconfigHandler

type KubeconfigHandler func(string, *v1alpha1.Kubeconfig) (*v1alpha1.Kubeconfig, error)

type KubeconfigIndexer

type KubeconfigIndexer func(obj *v1alpha1.Kubeconfig) ([]string, error)

type UserCache

type UserCache interface {
	Get(name string) (*v1alpha1.User, error)
	List(selector labels.Selector) ([]*v1alpha1.User, error)

	AddIndexer(indexName string, indexer UserIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha1.User, error)
}

type UserClient

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

type UserController

type UserController interface {
	generic.ControllerMeta
	UserClient

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

	Cache() UserCache
}

func NewUserController

func NewUserController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.UsersGetter, informer informers.UserInformer) UserController

type UserGeneratingHandler

type UserGeneratingHandler func(obj *v1alpha1.User, status v1alpha1.UserStatus) ([]runtime.Object, v1alpha1.UserStatus, error)

type UserHandler

type UserHandler func(string, *v1alpha1.User) (*v1alpha1.User, error)

type UserIndexer

type UserIndexer func(obj *v1alpha1.User) ([]string, error)

type UserStatusHandler

type UserStatusHandler func(obj *v1alpha1.User, status v1alpha1.UserStatus) (v1alpha1.UserStatus, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL