v3

package
v0.1.3 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromClusterHandlerToHandler added in v0.1.0 

func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler

func FromGlobalRoleHandlerToHandler added in v0.1.0 

func FromGlobalRoleHandlerToHandler(sync GlobalRoleHandler) generic.Handler

func FromRoleTemplateHandlerToHandler added in v0.1.0 

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 added in v0.1.0 

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

func UpdateGlobalRoleDeepCopyOnChange added in v0.1.0 

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

func UpdateRoleTemplateDeepCopyOnChange added in v0.1.0 

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 added in v0.1.0 

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 added in v0.1.0 

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

type ClusterIndexer added in v0.1.0 

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 added in v0.1.0 

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

type GlobalRoleHandler added in v0.1.0 

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

type GlobalRoleIndexer added in v0.1.0 

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 added in v0.1.0 

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

type RoleTemplateHandler added in v0.1.0 

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

type RoleTemplateIndexer added in v0.1.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.