v1alpha1

Documentation

Index

• func FromKubeconfigHandlerToHandler(sync KubeconfigHandler) generic.Handler
• func FromUserHandlerToHandler(sync UserHandler) generic.Handler
• func RegisterUserGeneratingHandler(ctx context.Context, controller UserController, apply apply.Apply, ...)
• func RegisterUserStatusHandler(ctx context.Context, controller UserController, condition condition.Cond, ...)
• func UpdateKubeconfigDeepCopyOnChange(client KubeconfigClient, obj *v1alpha1.Kubeconfig, ...) (*v1alpha1.Kubeconfig, error)
• func UpdateUserDeepCopyOnChange(client UserClient, obj *v1alpha1.User, ...) (*v1alpha1.User, error)
• type Interface
  • func New(controllerManager *generic.ControllerManager, ...) Interface
• type KubeconfigCache
• type KubeconfigClient
• type KubeconfigController
  • func NewKubeconfigController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) KubeconfigController
• type KubeconfigHandler
• type KubeconfigIndexer
• type UserCache
• type UserClient
• type UserController
  • func NewUserController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) UserController
• type UserGeneratingHandler
• type UserHandler
• type UserIndexer
• type UserStatusHandler

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
}

func NewKubeconfigController

func NewKubeconfigController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.KubeconfigsGetter, informer informers.KubeconfigInformer) KubeconfigController

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)