v3

package
v0.3.6-rc1 Latest Latest
Warning

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

Go to latest
Published: Jul 11, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromClusterHandlerToHandler

func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler

func FromClusterRoleTemplateBindingHandlerToHandler added in v0.1.6

func FromClusterRoleTemplateBindingHandlerToHandler(sync ClusterRoleTemplateBindingHandler) generic.Handler

func FromGlobalRoleHandlerToHandler

func FromGlobalRoleHandlerToHandler(sync GlobalRoleHandler) generic.Handler

func FromNodeHandlerToHandler

func FromNodeHandlerToHandler(sync NodeHandler) generic.Handler

func FromPodSecurityAdmissionConfigurationTemplateHandlerToHandler added in v0.3.2

func FromPodSecurityAdmissionConfigurationTemplateHandlerToHandler(sync PodSecurityAdmissionConfigurationTemplateHandler) generic.Handler

func FromProjectRoleTemplateBindingHandlerToHandler added in v0.1.6

func FromProjectRoleTemplateBindingHandlerToHandler(sync ProjectRoleTemplateBindingHandler) 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 RegisterNodeGeneratingHandler added in v0.3.6

func RegisterNodeGeneratingHandler(ctx context.Context, controller NodeController, apply apply.Apply,
	condition condition.Cond, name string, handler NodeGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterNodeStatusHandler added in v0.3.6

func RegisterNodeStatusHandler(ctx context.Context, controller NodeController, condition condition.Cond, name string, handler NodeStatusHandler)

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 UpdateNodeDeepCopyOnChange

func UpdateNodeDeepCopyOnChange(client NodeClient, obj *v3.Node, handler func(obj *v3.Node) (*v3.Node, error)) (*v3.Node, 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 ClusterRoleTemplateBindingCache added in v0.1.6

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

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

type ClusterRoleTemplateBindingClient added in v0.1.6

type ClusterRoleTemplateBindingClient interface {
	Create(*v3.ClusterRoleTemplateBinding) (*v3.ClusterRoleTemplateBinding, error)
	Update(*v3.ClusterRoleTemplateBinding) (*v3.ClusterRoleTemplateBinding, error)

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

type ClusterRoleTemplateBindingController added in v0.1.6

type ClusterRoleTemplateBindingController interface {
	generic.ControllerMeta
	ClusterRoleTemplateBindingClient

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

	Cache() ClusterRoleTemplateBindingCache
}

func NewClusterRoleTemplateBindingController added in v0.1.6

func NewClusterRoleTemplateBindingController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ClusterRoleTemplateBindingController

type ClusterRoleTemplateBindingHandler added in v0.1.6

type ClusterRoleTemplateBindingHandler func(string, *v3.ClusterRoleTemplateBinding) (*v3.ClusterRoleTemplateBinding, error)

type ClusterRoleTemplateBindingIndexer added in v0.1.6

type ClusterRoleTemplateBindingIndexer func(obj *v3.ClusterRoleTemplateBinding) ([]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
	ClusterRoleTemplateBinding() ClusterRoleTemplateBindingController
	GlobalRole() GlobalRoleController
	Node() NodeController
	PodSecurityAdmissionConfigurationTemplate() PodSecurityAdmissionConfigurationTemplateController
	ProjectRoleTemplateBinding() ProjectRoleTemplateBindingController
	RoleTemplate() RoleTemplateController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type NodeCache added in v0.3.6

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

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

type NodeClient added in v0.3.6

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

type NodeController added in v0.3.6

type NodeController interface {
	generic.ControllerMeta
	NodeClient

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

	Cache() NodeCache
}

func NewNodeController

func NewNodeController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) NodeController

type NodeGeneratingHandler added in v0.3.6

type NodeGeneratingHandler func(obj *v3.Node, status v3.NodeStatus) ([]runtime.Object, v3.NodeStatus, error)

type NodeHandler

type NodeHandler func(string, *v3.Node) (*v3.Node, error)

type NodeIndexer

type NodeIndexer func(obj *v3.Node) ([]string, error)

type NodeStatusHandler added in v0.3.6

type NodeStatusHandler func(obj *v3.Node, status v3.NodeStatus) (v3.NodeStatus, error)

type PodSecurityAdmissionConfigurationTemplateCache added in v0.3.2

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

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

type PodSecurityAdmissionConfigurationTemplateController added in v0.3.2

type PodSecurityAdmissionConfigurationTemplateController interface {
	generic.ControllerMeta
	PodSecurityAdmissionConfigurationTemplateClient

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

	Cache() PodSecurityAdmissionConfigurationTemplateCache
}

func NewPodSecurityAdmissionConfigurationTemplateController added in v0.3.2

func NewPodSecurityAdmissionConfigurationTemplateController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) PodSecurityAdmissionConfigurationTemplateController

type PodSecurityAdmissionConfigurationTemplateIndexer added in v0.3.2

type PodSecurityAdmissionConfigurationTemplateIndexer func(obj *v3.PodSecurityAdmissionConfigurationTemplate) ([]string, error)

type ProjectRoleTemplateBindingCache added in v0.1.6

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

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

type ProjectRoleTemplateBindingClient added in v0.1.6

type ProjectRoleTemplateBindingClient interface {
	Create(*v3.ProjectRoleTemplateBinding) (*v3.ProjectRoleTemplateBinding, error)
	Update(*v3.ProjectRoleTemplateBinding) (*v3.ProjectRoleTemplateBinding, error)

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

type ProjectRoleTemplateBindingController added in v0.1.6

type ProjectRoleTemplateBindingController interface {
	generic.ControllerMeta
	ProjectRoleTemplateBindingClient

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

	Cache() ProjectRoleTemplateBindingCache
}

func NewProjectRoleTemplateBindingController added in v0.1.6

func NewProjectRoleTemplateBindingController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ProjectRoleTemplateBindingController

type ProjectRoleTemplateBindingHandler added in v0.1.6

type ProjectRoleTemplateBindingHandler func(string, *v3.ProjectRoleTemplateBinding) (*v3.ProjectRoleTemplateBinding, error)

type ProjectRoleTemplateBindingIndexer added in v0.1.6

type ProjectRoleTemplateBindingIndexer func(obj *v3.ProjectRoleTemplateBinding) ([]string, error)

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)

Jump to

Keyboard shortcuts

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