v1alpha1

Documentation

Index

• func FromClusterGroupHandlerToHandler(sync ClusterGroupHandler) generic.Handler
• func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler
• func FromClusterRegistrationTokenHandlerToHandler(sync ClusterRegistrationTokenHandler) generic.Handler
• func FromGitRepoHandlerToHandler(sync GitRepoHandler) generic.Handler
• func RegisterClusterGeneratingHandler(ctx context.Context, controller ClusterController, apply apply.Apply, ...)
• func RegisterClusterGroupGeneratingHandler(ctx context.Context, controller ClusterGroupController, apply apply.Apply, ...)
• func RegisterClusterGroupStatusHandler(ctx context.Context, controller ClusterGroupController, ...)
• func RegisterClusterRegistrationTokenGeneratingHandler(ctx context.Context, controller ClusterRegistrationTokenController, ...)
• func RegisterClusterRegistrationTokenStatusHandler(ctx context.Context, controller ClusterRegistrationTokenController, ...)
• func RegisterClusterStatusHandler(ctx context.Context, controller ClusterController, condition condition.Cond, ...)
• func RegisterGitRepoGeneratingHandler(ctx context.Context, controller GitRepoController, apply apply.Apply, ...)
• func RegisterGitRepoStatusHandler(ctx context.Context, controller GitRepoController, condition condition.Cond, ...)
• func UpdateClusterDeepCopyOnChange(client ClusterClient, obj *v1alpha1.Cluster, ...) (*v1alpha1.Cluster, error)
• func UpdateClusterGroupDeepCopyOnChange(client ClusterGroupClient, obj *v1alpha1.ClusterGroup, ...) (*v1alpha1.ClusterGroup, error)
• func UpdateClusterRegistrationTokenDeepCopyOnChange(client ClusterRegistrationTokenClient, obj *v1alpha1.ClusterRegistrationToken, ...) (*v1alpha1.ClusterRegistrationToken, error)
• func UpdateGitRepoDeepCopyOnChange(client GitRepoClient, obj *v1alpha1.GitRepo, ...) (*v1alpha1.GitRepo, error)
• type ClusterCache
• type ClusterClient
• type ClusterController
  • func NewClusterController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) ClusterController
• type ClusterGeneratingHandler
• type ClusterGroupCache
• type ClusterGroupClient
• type ClusterGroupController
  • func NewClusterGroupController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) ClusterGroupController
• type ClusterGroupGeneratingHandler
• type ClusterGroupHandler
• type ClusterGroupIndexer
• type ClusterGroupStatusHandler
• type ClusterHandler
• type ClusterIndexer
• type ClusterRegistrationTokenCache
• type ClusterRegistrationTokenClient
• type ClusterRegistrationTokenController
  • func NewClusterRegistrationTokenController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) ClusterRegistrationTokenController
• type ClusterRegistrationTokenGeneratingHandler
• type ClusterRegistrationTokenHandler
• type ClusterRegistrationTokenIndexer
• type ClusterRegistrationTokenStatusHandler
• type ClusterStatusHandler
• type GitRepoCache
• type GitRepoClient
• type GitRepoController
  • func NewGitRepoController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) GitRepoController
• type GitRepoGeneratingHandler
• type GitRepoHandler
• type GitRepoIndexer
• type GitRepoStatusHandler
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface

Functions

func FromClusterGroupHandlerToHandler

func FromClusterGroupHandlerToHandler(sync ClusterGroupHandler) generic.Handler

func FromClusterHandlerToHandler

func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler

func FromClusterRegistrationTokenHandlerToHandler

func FromClusterRegistrationTokenHandlerToHandler(sync ClusterRegistrationTokenHandler) generic.Handler

func FromGitRepoHandlerToHandler

func FromGitRepoHandlerToHandler(sync GitRepoHandler) 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 RegisterClusterGroupGeneratingHandler

func RegisterClusterGroupGeneratingHandler(ctx context.Context, controller ClusterGroupController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterGroupGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterClusterGroupStatusHandler

func RegisterClusterGroupStatusHandler(ctx context.Context, controller ClusterGroupController, condition condition.Cond, name string, handler ClusterGroupStatusHandler)

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 RegisterGitRepoGeneratingHandler

func RegisterGitRepoGeneratingHandler(ctx context.Context, controller GitRepoController, apply apply.Apply,
	condition condition.Cond, name string, handler GitRepoGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterGitRepoStatusHandler

func RegisterGitRepoStatusHandler(ctx context.Context, controller GitRepoController, condition condition.Cond, name string, handler GitRepoStatusHandler)

func UpdateClusterDeepCopyOnChange

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

func UpdateClusterGroupDeepCopyOnChange

func UpdateClusterGroupDeepCopyOnChange(client ClusterGroupClient, obj *v1alpha1.ClusterGroup, handler func(obj *v1alpha1.ClusterGroup) (*v1alpha1.ClusterGroup, error)) (*v1alpha1.ClusterGroup, error)

func UpdateClusterRegistrationTokenDeepCopyOnChange

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

func UpdateGitRepoDeepCopyOnChange

func UpdateGitRepoDeepCopyOnChange(client GitRepoClient, obj *v1alpha1.GitRepo, handler func(obj *v1alpha1.GitRepo) (*v1alpha1.GitRepo, error)) (*v1alpha1.GitRepo, error)

Types

type ClusterCache

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

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

type ClusterClient

type ClusterClient interface {
	Create(*v1alpha1.Cluster) (*v1alpha1.Cluster, error)
	Update(*v1alpha1.Cluster) (*v1alpha1.Cluster, error)
	UpdateStatus(*v1alpha1.Cluster) (*v1alpha1.Cluster, error)
	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1alpha1.Cluster, error)
	List(namespace string, opts metav1.ListOptions) (*v1alpha1.ClusterList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.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(namespace, name string)
	EnqueueAfter(namespace, 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 *v1alpha1.Cluster, status v1alpha1.ClusterStatus) ([]runtime.Object, v1alpha1.ClusterStatus, error)

type ClusterGroupCache

type ClusterGroupCache interface {
	Get(namespace, name string) (*v1alpha1.ClusterGroup, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha1.ClusterGroup, error)

	AddIndexer(indexName string, indexer ClusterGroupIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha1.ClusterGroup, error)
}

type ClusterGroupClient

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

type ClusterGroupController

type ClusterGroupController interface {
	generic.ControllerMeta
	ClusterGroupClient

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

	Cache() ClusterGroupCache
}

func NewClusterGroupController

func NewClusterGroupController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ClusterGroupController

type ClusterGroupGeneratingHandler

type ClusterGroupGeneratingHandler func(obj *v1alpha1.ClusterGroup, status v1alpha1.ClusterGroupStatus) ([]runtime.Object, v1alpha1.ClusterGroupStatus, error)

type ClusterGroupHandler

type ClusterGroupHandler func(string, *v1alpha1.ClusterGroup) (*v1alpha1.ClusterGroup, error)

type ClusterGroupIndexer

type ClusterGroupIndexer func(obj *v1alpha1.ClusterGroup) ([]string, error)

type ClusterGroupStatusHandler

type ClusterGroupStatusHandler func(obj *v1alpha1.ClusterGroup, status v1alpha1.ClusterGroupStatus) (v1alpha1.ClusterGroupStatus, error)

type ClusterHandler

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

type ClusterIndexer

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

type ClusterRegistrationTokenCache

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

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

type ClusterRegistrationTokenClient

type ClusterRegistrationTokenClient interface {
	Create(*v1alpha1.ClusterRegistrationToken) (*v1alpha1.ClusterRegistrationToken, error)
	Update(*v1alpha1.ClusterRegistrationToken) (*v1alpha1.ClusterRegistrationToken, error)
	UpdateStatus(*v1alpha1.ClusterRegistrationToken) (*v1alpha1.ClusterRegistrationToken, error)
	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1alpha1.ClusterRegistrationToken, error)
	List(namespace string, opts metav1.ListOptions) (*v1alpha1.ClusterRegistrationTokenList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.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 *v1alpha1.ClusterRegistrationToken, status v1alpha1.ClusterRegistrationTokenStatus) ([]runtime.Object, v1alpha1.ClusterRegistrationTokenStatus, error)

type ClusterRegistrationTokenHandler

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

type ClusterRegistrationTokenIndexer

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

type ClusterRegistrationTokenStatusHandler

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

type ClusterStatusHandler

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

type GitRepoCache

type GitRepoCache interface {
	Get(namespace, name string) (*v1alpha1.GitRepo, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha1.GitRepo, error)

	AddIndexer(indexName string, indexer GitRepoIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha1.GitRepo, error)
}

type GitRepoClient

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

type GitRepoController

type GitRepoController interface {
	generic.ControllerMeta
	GitRepoClient

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

	Cache() GitRepoCache
}

func NewGitRepoController

func NewGitRepoController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) GitRepoController

type GitRepoGeneratingHandler

type GitRepoGeneratingHandler func(obj *v1alpha1.GitRepo, status v1alpha1.GitRepoStatus) ([]runtime.Object, v1alpha1.GitRepoStatus, error)

type GitRepoHandler

type GitRepoHandler func(string, *v1alpha1.GitRepo) (*v1alpha1.GitRepo, error)

type GitRepoIndexer

type GitRepoIndexer func(obj *v1alpha1.GitRepo) ([]string, error)

type GitRepoStatusHandler

type GitRepoStatusHandler func(obj *v1alpha1.GitRepo, status v1alpha1.GitRepoStatus) (v1alpha1.GitRepoStatus, error)

type Interface

type Interface interface {
	Cluster() ClusterController
	ClusterGroup() ClusterGroupController
	ClusterRegistrationToken() ClusterRegistrationTokenController
	GitRepo() GitRepoController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface