v3

package
v0.1.3-rc5 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2021 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 FromClusterRegistrationTokenHandlerToHandler 

func FromClusterRegistrationTokenHandlerToHandler(sync ClusterRegistrationTokenHandler) generic.Handler

func FromClusterRoleTemplateBindingHandlerToHandler 

func FromClusterRoleTemplateBindingHandlerToHandler(sync ClusterRoleTemplateBindingHandler) generic.Handler

func FromFleetWorkspaceHandlerToHandler 

func FromFleetWorkspaceHandlerToHandler(sync FleetWorkspaceHandler) generic.Handler

func FromProjectHandlerToHandler 

func FromProjectHandlerToHandler(sync ProjectHandler) generic.Handler

func FromProjectRoleTemplateBindingHandlerToHandler 

func FromProjectRoleTemplateBindingHandlerToHandler(sync ProjectRoleTemplateBindingHandler) generic.Handler

func FromRoleTemplateHandlerToHandler 

func FromRoleTemplateHandlerToHandler(sync RoleTemplateHandler) generic.Handler

func FromSettingHandlerToHandler 

func FromSettingHandlerToHandler(sync SettingHandler) generic.Handler

func FromTokenHandlerToHandler 

func FromTokenHandlerToHandler(sync TokenHandler) generic.Handler

func FromUserHandlerToHandler 

func FromUserHandlerToHandler(sync UserHandler) 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 RegisterClusterRegistrationTokenGeneratingHandler 

func RegisterClusterRegistrationTokenGeneratingHandler(ctx context.Context, controller ClusterRegistrationTokenController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterRegistrationTokenGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterClusterRegistrationTokenStatusHandler 

func RegisterClusterRegistrationTokenStatusHandler(ctx context.Context, controller ClusterRegistrationTokenController, condition condition.Cond, name string, handler ClusterRegistrationTokenStatusHandler)

func RegisterClusterStatusHandler 

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

func RegisterFleetWorkspaceGeneratingHandler 

func RegisterFleetWorkspaceGeneratingHandler(ctx context.Context, controller FleetWorkspaceController, apply apply.Apply,
	condition condition.Cond, name string, handler FleetWorkspaceGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterFleetWorkspaceStatusHandler 

func RegisterFleetWorkspaceStatusHandler(ctx context.Context, controller FleetWorkspaceController, condition condition.Cond, name string, handler FleetWorkspaceStatusHandler)

func RegisterProjectGeneratingHandler 

func RegisterProjectGeneratingHandler(ctx context.Context, controller ProjectController, apply apply.Apply,
	condition condition.Cond, name string, handler ProjectGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterProjectStatusHandler 

func RegisterProjectStatusHandler(ctx context.Context, controller ProjectController, condition condition.Cond, name string, handler ProjectStatusHandler)

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 UpdateClusterDeepCopyOnChange 

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

func UpdateClusterRegistrationTokenDeepCopyOnChange 

func UpdateClusterRegistrationTokenDeepCopyOnChange(client ClusterRegistrationTokenClient, obj *v3.ClusterRegistrationToken, handler func(obj *v3.ClusterRegistrationToken) (*v3.ClusterRegistrationToken, error)) (*v3.ClusterRegistrationToken, error)

func UpdateClusterRoleTemplateBindingDeepCopyOnChange 

func UpdateClusterRoleTemplateBindingDeepCopyOnChange(client ClusterRoleTemplateBindingClient, obj *v3.ClusterRoleTemplateBinding, handler func(obj *v3.ClusterRoleTemplateBinding) (*v3.ClusterRoleTemplateBinding, error)) (*v3.ClusterRoleTemplateBinding, error)

func UpdateFleetWorkspaceDeepCopyOnChange 

func UpdateFleetWorkspaceDeepCopyOnChange(client FleetWorkspaceClient, obj *v3.FleetWorkspace, handler func(obj *v3.FleetWorkspace) (*v3.FleetWorkspace, error)) (*v3.FleetWorkspace, error)

func UpdateProjectDeepCopyOnChange 

func UpdateProjectDeepCopyOnChange(client ProjectClient, obj *v3.Project, handler func(obj *v3.Project) (*v3.Project, error)) (*v3.Project, error)

func UpdateProjectRoleTemplateBindingDeepCopyOnChange 

func UpdateProjectRoleTemplateBindingDeepCopyOnChange(client ProjectRoleTemplateBindingClient, obj *v3.ProjectRoleTemplateBinding, handler func(obj *v3.ProjectRoleTemplateBinding) (*v3.ProjectRoleTemplateBinding, error)) (*v3.ProjectRoleTemplateBinding, error)

func UpdateRoleTemplateDeepCopyOnChange 

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

func UpdateSettingDeepCopyOnChange 

func UpdateSettingDeepCopyOnChange(client SettingClient, obj *v3.Setting, handler func(obj *v3.Setting) (*v3.Setting, error)) (*v3.Setting, error)

func UpdateTokenDeepCopyOnChange 

func UpdateTokenDeepCopyOnChange(client TokenClient, obj *v3.Token, handler func(obj *v3.Token) (*v3.Token, error)) (*v3.Token, error)

func UpdateUserDeepCopyOnChange 

func UpdateUserDeepCopyOnChange(client UserClient, obj *v3.User, handler func(obj *v3.User) (*v3.User, error)) (*v3.User, 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 ClusterRegistrationTokenCache 

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

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

type ClusterRegistrationTokenClient 

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

type ClusterRegistrationTokenController 

type ClusterRegistrationTokenController interface {
	generic.ControllerMeta
	ClusterRegistrationTokenClient

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

	Cache() ClusterRegistrationTokenCache
}

func NewClusterRegistrationTokenController 

func NewClusterRegistrationTokenController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ClusterRegistrationTokenController

type ClusterRegistrationTokenGeneratingHandler 

type ClusterRegistrationTokenGeneratingHandler func(obj *v3.ClusterRegistrationToken, status v3.ClusterRegistrationTokenStatus) ([]runtime.Object, v3.ClusterRegistrationTokenStatus, error)

type ClusterRegistrationTokenHandler 

type ClusterRegistrationTokenHandler func(string, *v3.ClusterRegistrationToken) (*v3.ClusterRegistrationToken, error)

type ClusterRegistrationTokenIndexer 

type ClusterRegistrationTokenIndexer func(obj *v3.ClusterRegistrationToken) ([]string, error)

type ClusterRegistrationTokenStatusHandler 

type ClusterRegistrationTokenStatusHandler func(obj *v3.ClusterRegistrationToken, status v3.ClusterRegistrationTokenStatus) (v3.ClusterRegistrationTokenStatus, error)

type ClusterRoleTemplateBindingCache 

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 

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 

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 

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

type ClusterRoleTemplateBindingHandler 

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

type ClusterRoleTemplateBindingIndexer 

type ClusterRoleTemplateBindingIndexer func(obj *v3.ClusterRoleTemplateBinding) ([]string, error)

type ClusterStatusHandler 

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

type FleetWorkspaceCache 

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

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

type FleetWorkspaceClient 

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

type FleetWorkspaceController 

type FleetWorkspaceController interface {
	generic.ControllerMeta
	FleetWorkspaceClient

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

	Cache() FleetWorkspaceCache
}

func NewFleetWorkspaceController 

func NewFleetWorkspaceController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) FleetWorkspaceController

type FleetWorkspaceGeneratingHandler 

type FleetWorkspaceGeneratingHandler func(obj *v3.FleetWorkspace, status v3.FleetWorkspaceStatus) ([]runtime.Object, v3.FleetWorkspaceStatus, error)

type FleetWorkspaceHandler 

type FleetWorkspaceHandler func(string, *v3.FleetWorkspace) (*v3.FleetWorkspace, error)

type FleetWorkspaceIndexer 

type FleetWorkspaceIndexer func(obj *v3.FleetWorkspace) ([]string, error)

type FleetWorkspaceStatusHandler 

type FleetWorkspaceStatusHandler func(obj *v3.FleetWorkspace, status v3.FleetWorkspaceStatus) (v3.FleetWorkspaceStatus, error)

type Interface 

type Interface interface {
	Cluster() ClusterController
	ClusterRegistrationToken() ClusterRegistrationTokenController
	ClusterRoleTemplateBinding() ClusterRoleTemplateBindingController
	FleetWorkspace() FleetWorkspaceController
	Project() ProjectController
	ProjectRoleTemplateBinding() ProjectRoleTemplateBindingController
	RoleTemplate() RoleTemplateController
	Setting() SettingController
	Token() TokenController
	User() UserController
}

func New 

func New(controllerFactory controller.SharedControllerFactory) Interface

type ProjectCache 

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

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

type ProjectClient 

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

type ProjectController 

type ProjectController interface {
	generic.ControllerMeta
	ProjectClient

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

	Cache() ProjectCache
}

func NewProjectController 

func NewProjectController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ProjectController

type ProjectGeneratingHandler 

type ProjectGeneratingHandler func(obj *v3.Project, status v3.ProjectStatus) ([]runtime.Object, v3.ProjectStatus, error)

type ProjectHandler 

type ProjectHandler func(string, *v3.Project) (*v3.Project, error)

type ProjectIndexer 

type ProjectIndexer func(obj *v3.Project) ([]string, error)

type ProjectRoleTemplateBindingCache 

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 

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 

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 

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

type ProjectRoleTemplateBindingHandler 

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

type ProjectRoleTemplateBindingIndexer 

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

type ProjectStatusHandler 

type ProjectStatusHandler func(obj *v3.Project, status v3.ProjectStatus) (v3.ProjectStatus, 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)

type SettingCache 

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

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

type SettingClient 

type SettingClient interface {
	Create(*v3.Setting) (*v3.Setting, error)
	Update(*v3.Setting) (*v3.Setting, error)

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

type SettingController 

type SettingController interface {
	generic.ControllerMeta
	SettingClient

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

	Cache() SettingCache
}

func NewSettingController 

func NewSettingController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) SettingController

type SettingHandler 

type SettingHandler func(string, *v3.Setting) (*v3.Setting, error)

type SettingIndexer 

type SettingIndexer func(obj *v3.Setting) ([]string, error)

type TokenCache 

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

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

type TokenClient 

type TokenClient interface {
	Create(*v3.Token) (*v3.Token, error)
	Update(*v3.Token) (*v3.Token, error)

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

type TokenController 

type TokenController interface {
	generic.ControllerMeta
	TokenClient

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

	Cache() TokenCache
}

func NewTokenController 

func NewTokenController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) TokenController

type TokenHandler 

type TokenHandler func(string, *v3.Token) (*v3.Token, error)

type TokenIndexer 

type TokenIndexer func(obj *v3.Token) ([]string, error)

type UserCache 

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

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

type UserClient 

type UserClient interface {
	Create(*v3.User) (*v3.User, error)
	Update(*v3.User) (*v3.User, error)
	UpdateStatus(*v3.User) (*v3.User, error)
	Delete(name string, options *metav1.DeleteOptions) error
	Get(name string, options metav1.GetOptions) (*v3.User, error)
	List(opts metav1.ListOptions) (*v3.UserList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
	Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v3.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, resource string, namespaced bool, controller controller.SharedControllerFactory) UserController

type UserGeneratingHandler 

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

type UserHandler 

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

type UserIndexer 

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

type UserStatusHandler 

type UserStatusHandler func(obj *v3.User, status v3.UserStatus) (v3.UserStatus, 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.