v3

Documentation

Index

• func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler
• func FromGlobalRoleHandlerToHandler(sync GlobalRoleHandler) generic.Handler
• func FromRoleTemplateHandlerToHandler(sync RoleTemplateHandler) generic.Handler
• func RegisterClusterGeneratingHandler(ctx context.Context, controller ClusterController, apply apply.Apply, ...)
• func RegisterClusterStatusHandler(ctx context.Context, controller ClusterController, condition condition.Cond, ...)
• func UpdateClusterDeepCopyOnChange(client ClusterClient, obj *v3.Cluster, ...) (*v3.Cluster, error)
• func UpdateGlobalRoleDeepCopyOnChange(client GlobalRoleClient, obj *v3.GlobalRole, ...) (*v3.GlobalRole, error)
• func UpdateRoleTemplateDeepCopyOnChange(client RoleTemplateClient, obj *v3.RoleTemplate, ...) (*v3.RoleTemplate, error)
• type ClusterCache
• type ClusterClient
• type ClusterController
  • func NewClusterController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) ClusterController
• type ClusterGeneratingHandler
• type ClusterHandler
• type ClusterIndexer
• type ClusterStatusHandler
• type GlobalRoleCache
• type GlobalRoleClient
• type GlobalRoleController
  • func NewGlobalRoleController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) GlobalRoleController
• type GlobalRoleHandler
• type GlobalRoleIndexer
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type RoleTemplateCache
• type RoleTemplateClient
• type RoleTemplateController
  • func NewRoleTemplateController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) RoleTemplateController
• type RoleTemplateHandler
• type RoleTemplateIndexer

Functions

func FromClusterHandlerToHandler

func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler

func FromGlobalRoleHandlerToHandler

func FromGlobalRoleHandlerToHandler(sync GlobalRoleHandler) generic.Handler

func FromRoleTemplateHandlerToHandler

func FromRoleTemplateHandlerToHandler(sync RoleTemplateHandler) generic.Handler

func RegisterClusterGeneratingHandler

func RegisterClusterGeneratingHandler(ctx context.Context, controller ClusterController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterClusterStatusHandler

func RegisterClusterStatusHandler(ctx context.Context, controller ClusterController, condition condition.Cond, name string, handler ClusterStatusHandler)

func UpdateClusterDeepCopyOnChange

func UpdateClusterDeepCopyOnChange(client ClusterClient, obj *v3.Cluster, handler func(obj *v3.Cluster) (*v3.Cluster, error)) (*v3.Cluster, error)

func UpdateGlobalRoleDeepCopyOnChange

func UpdateGlobalRoleDeepCopyOnChange(client GlobalRoleClient, obj *v3.GlobalRole, handler func(obj *v3.GlobalRole) (*v3.GlobalRole, error)) (*v3.GlobalRole, error)

func UpdateRoleTemplateDeepCopyOnChange

func UpdateRoleTemplateDeepCopyOnChange(client RoleTemplateClient, obj *v3.RoleTemplate, handler func(obj *v3.RoleTemplate) (*v3.RoleTemplate, error)) (*v3.RoleTemplate, error)

Types

type ClusterCache

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

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

type ClusterClient

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

type ClusterController

type ClusterController interface {
	generic.ControllerMeta
	ClusterClient

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

	Cache() ClusterCache
}

func NewClusterController

func NewClusterController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ClusterController

type ClusterGeneratingHandler

type ClusterGeneratingHandler func(obj *v3.Cluster, status v3.ClusterStatus) ([]runtime.Object, v3.ClusterStatus, error)

type ClusterHandler

type ClusterHandler func(string, *v3.Cluster) (*v3.Cluster, error)

type ClusterIndexer

type ClusterIndexer func(obj *v3.Cluster) ([]string, error)

type ClusterStatusHandler

type ClusterStatusHandler func(obj *v3.Cluster, status v3.ClusterStatus) (v3.ClusterStatus, error)

type GlobalRoleCache

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

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

type GlobalRoleClient

type GlobalRoleClient interface {
	Create(*v3.GlobalRole) (*v3.GlobalRole, error)
	Update(*v3.GlobalRole) (*v3.GlobalRole, error)

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

type GlobalRoleController

type GlobalRoleController interface {
	generic.ControllerMeta
	GlobalRoleClient

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

	Cache() GlobalRoleCache
}

func NewGlobalRoleController

func NewGlobalRoleController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) GlobalRoleController

type GlobalRoleHandler

type GlobalRoleHandler func(string, *v3.GlobalRole) (*v3.GlobalRole, error)

type GlobalRoleIndexer

type GlobalRoleIndexer func(obj *v3.GlobalRole) ([]string, error)

type Interface

type Interface interface {
	Cluster() ClusterController
	GlobalRole() GlobalRoleController
	RoleTemplate() RoleTemplateController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type RoleTemplateCache

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

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

type RoleTemplateClient

type RoleTemplateClient interface {
	Create(*v3.RoleTemplate) (*v3.RoleTemplate, error)
	Update(*v3.RoleTemplate) (*v3.RoleTemplate, error)

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

type RoleTemplateController

type RoleTemplateController interface {
	generic.ControllerMeta
	RoleTemplateClient

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

	Cache() RoleTemplateCache
}

func NewRoleTemplateController

func NewRoleTemplateController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) RoleTemplateController

type RoleTemplateHandler

type RoleTemplateHandler func(string, *v3.RoleTemplate) (*v3.RoleTemplate, error)

type RoleTemplateIndexer

type RoleTemplateIndexer func(obj *v3.RoleTemplate) ([]string, error)