v1alpha1

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Oct 21, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromBundleDeploymentHandlerToHandler 

func FromBundleDeploymentHandlerToHandler(sync BundleDeploymentHandler) generic.Handler

func FromBundleHandlerToHandler 

func FromBundleHandlerToHandler(sync BundleHandler) generic.Handler

func FromBundleNamespaceMappingHandlerToHandler added in v0.3.0 

func FromBundleNamespaceMappingHandlerToHandler(sync BundleNamespaceMappingHandler) generic.Handler

func FromClusterGroupHandlerToHandler 

func FromClusterGroupHandlerToHandler(sync ClusterGroupHandler) generic.Handler

func FromClusterHandlerToHandler 

func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler

func FromClusterRegistrationHandlerToHandler added in v0.3.0 

func FromClusterRegistrationHandlerToHandler(sync ClusterRegistrationHandler) generic.Handler

func FromClusterRegistrationTokenHandlerToHandler added in v0.3.0 

func FromClusterRegistrationTokenHandlerToHandler(sync ClusterRegistrationTokenHandler) generic.Handler

func FromContentHandlerToHandler 

func FromContentHandlerToHandler(sync ContentHandler) generic.Handler

func FromGitRepoHandlerToHandler added in v0.3.0 

func FromGitRepoHandlerToHandler(sync GitRepoHandler) generic.Handler

func FromGitRepoRestrictionHandlerToHandler added in v0.3.0 

func FromGitRepoRestrictionHandlerToHandler(sync GitRepoRestrictionHandler) generic.Handler

func RegisterBundleDeploymentGeneratingHandler 

func RegisterBundleDeploymentGeneratingHandler(ctx context.Context, controller BundleDeploymentController, apply apply.Apply,
	condition condition.Cond, name string, handler BundleDeploymentGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterBundleDeploymentStatusHandler 

func RegisterBundleDeploymentStatusHandler(ctx context.Context, controller BundleDeploymentController, condition condition.Cond, name string, handler BundleDeploymentStatusHandler)

func RegisterBundleGeneratingHandler 

func RegisterBundleGeneratingHandler(ctx context.Context, controller BundleController, apply apply.Apply,
	condition condition.Cond, name string, handler BundleGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterBundleStatusHandler 

func RegisterBundleStatusHandler(ctx context.Context, controller BundleController, condition condition.Cond, name string, handler BundleStatusHandler)

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

func RegisterClusterRegistrationGeneratingHandler(ctx context.Context, controller ClusterRegistrationController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterRegistrationGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterClusterRegistrationStatusHandler added in v0.3.0 

func RegisterClusterRegistrationStatusHandler(ctx context.Context, controller ClusterRegistrationController, condition condition.Cond, name string, handler ClusterRegistrationStatusHandler)

func RegisterClusterRegistrationTokenGeneratingHandler added in v0.3.0 

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

func RegisterClusterRegistrationTokenStatusHandler added in v0.3.0 

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

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

func RegisterGitRepoStatusHandler added in v0.3.0 

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

func UpdateBundleDeepCopyOnChange 

func UpdateBundleDeepCopyOnChange(client BundleClient, obj *v1alpha1.Bundle, handler func(obj *v1alpha1.Bundle) (*v1alpha1.Bundle, error)) (*v1alpha1.Bundle, error)

func UpdateBundleDeploymentDeepCopyOnChange 

func UpdateBundleDeploymentDeepCopyOnChange(client BundleDeploymentClient, obj *v1alpha1.BundleDeployment, handler func(obj *v1alpha1.BundleDeployment) (*v1alpha1.BundleDeployment, error)) (*v1alpha1.BundleDeployment, error)

func UpdateBundleNamespaceMappingDeepCopyOnChange added in v0.3.0 

func UpdateBundleNamespaceMappingDeepCopyOnChange(client BundleNamespaceMappingClient, obj *v1alpha1.BundleNamespaceMapping, handler func(obj *v1alpha1.BundleNamespaceMapping) (*v1alpha1.BundleNamespaceMapping, error)) (*v1alpha1.BundleNamespaceMapping, error)

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

func UpdateClusterRegistrationDeepCopyOnChange(client ClusterRegistrationClient, obj *v1alpha1.ClusterRegistration, handler func(obj *v1alpha1.ClusterRegistration) (*v1alpha1.ClusterRegistration, error)) (*v1alpha1.ClusterRegistration, error)

func UpdateClusterRegistrationTokenDeepCopyOnChange added in v0.3.0 

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

func UpdateContentDeepCopyOnChange 

func UpdateContentDeepCopyOnChange(client ContentClient, obj *v1alpha1.Content, handler func(obj *v1alpha1.Content) (*v1alpha1.Content, error)) (*v1alpha1.Content, error)

func UpdateGitRepoDeepCopyOnChange added in v0.3.0 

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

func UpdateGitRepoRestrictionDeepCopyOnChange added in v0.3.0 

func UpdateGitRepoRestrictionDeepCopyOnChange(client GitRepoRestrictionClient, obj *v1alpha1.GitRepoRestriction, handler func(obj *v1alpha1.GitRepoRestriction) (*v1alpha1.GitRepoRestriction, error)) (*v1alpha1.GitRepoRestriction, error)

Types

type BundleCache 

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

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

type BundleClient 

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

type BundleController 

type BundleController interface {
	generic.ControllerMeta
	BundleClient

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

	Cache() BundleCache
}

func NewBundleController 

func NewBundleController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) BundleController

type BundleDeploymentCache 

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

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

type BundleDeploymentClient 

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

type BundleDeploymentController 

type BundleDeploymentController interface {
	generic.ControllerMeta
	BundleDeploymentClient

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

	Cache() BundleDeploymentCache
}

func NewBundleDeploymentController 

func NewBundleDeploymentController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) BundleDeploymentController

type BundleDeploymentGeneratingHandler 

type BundleDeploymentGeneratingHandler func(obj *v1alpha1.BundleDeployment, status v1alpha1.BundleDeploymentStatus) ([]runtime.Object, v1alpha1.BundleDeploymentStatus, error)

type BundleDeploymentHandler 

type BundleDeploymentHandler func(string, *v1alpha1.BundleDeployment) (*v1alpha1.BundleDeployment, error)

type BundleDeploymentIndexer 

type BundleDeploymentIndexer func(obj *v1alpha1.BundleDeployment) ([]string, error)

type BundleDeploymentStatusHandler 

type BundleDeploymentStatusHandler func(obj *v1alpha1.BundleDeployment, status v1alpha1.BundleDeploymentStatus) (v1alpha1.BundleDeploymentStatus, error)

type BundleGeneratingHandler 

type BundleGeneratingHandler func(obj *v1alpha1.Bundle, status v1alpha1.BundleStatus) ([]runtime.Object, v1alpha1.BundleStatus, error)

type BundleHandler 

type BundleHandler func(string, *v1alpha1.Bundle) (*v1alpha1.Bundle, error)

type BundleIndexer 

type BundleIndexer func(obj *v1alpha1.Bundle) ([]string, error)

type BundleNamespaceMappingCache added in v0.3.0 

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

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

type BundleNamespaceMappingClient added in v0.3.0 

type BundleNamespaceMappingClient interface {
	Create(*v1alpha1.BundleNamespaceMapping) (*v1alpha1.BundleNamespaceMapping, error)
	Update(*v1alpha1.BundleNamespaceMapping) (*v1alpha1.BundleNamespaceMapping, error)

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

type BundleNamespaceMappingController added in v0.3.0 

type BundleNamespaceMappingController interface {
	generic.ControllerMeta
	BundleNamespaceMappingClient

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

	Cache() BundleNamespaceMappingCache
}

func NewBundleNamespaceMappingController added in v0.3.0 

func NewBundleNamespaceMappingController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) BundleNamespaceMappingController

type BundleNamespaceMappingHandler added in v0.3.0 

type BundleNamespaceMappingHandler func(string, *v1alpha1.BundleNamespaceMapping) (*v1alpha1.BundleNamespaceMapping, error)

type BundleNamespaceMappingIndexer added in v0.3.0 

type BundleNamespaceMappingIndexer func(obj *v1alpha1.BundleNamespaceMapping) ([]string, error)

type BundleStatusHandler 

type BundleStatusHandler func(obj *v1alpha1.Bundle, status v1alpha1.BundleStatus) (v1alpha1.BundleStatus, error)

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

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

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

type ClusterRegistrationClient added in v0.3.0 

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

type ClusterRegistrationController added in v0.3.0 

type ClusterRegistrationController interface {
	generic.ControllerMeta
	ClusterRegistrationClient

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

	Cache() ClusterRegistrationCache
}

func NewClusterRegistrationController added in v0.3.0 

func NewClusterRegistrationController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ClusterRegistrationController

type ClusterRegistrationGeneratingHandler added in v0.3.0 

type ClusterRegistrationGeneratingHandler func(obj *v1alpha1.ClusterRegistration, status v1alpha1.ClusterRegistrationStatus) ([]runtime.Object, v1alpha1.ClusterRegistrationStatus, error)

type ClusterRegistrationHandler added in v0.3.0 

type ClusterRegistrationHandler func(string, *v1alpha1.ClusterRegistration) (*v1alpha1.ClusterRegistration, error)

type ClusterRegistrationIndexer added in v0.3.0 

type ClusterRegistrationIndexer func(obj *v1alpha1.ClusterRegistration) ([]string, error)

type ClusterRegistrationStatusHandler added in v0.3.0 

type ClusterRegistrationStatusHandler func(obj *v1alpha1.ClusterRegistration, status v1alpha1.ClusterRegistrationStatus) (v1alpha1.ClusterRegistrationStatus, error)

type ClusterRegistrationTokenCache added in v0.3.0 

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

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

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

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

type ClusterRegistrationTokenGeneratingHandler added in v0.3.0 

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

type ClusterRegistrationTokenHandler added in v0.3.0 

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

type ClusterRegistrationTokenIndexer added in v0.3.0 

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

type ClusterRegistrationTokenStatusHandler added in v0.3.0 

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 ContentCache 

type ContentCache interface {
	Get(name string) (*v1alpha1.Content, error)
	List(selector labels.Selector) ([]*v1alpha1.Content, error)

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

type ContentClient 

type ContentClient interface {
	Create(*v1alpha1.Content) (*v1alpha1.Content, error)
	Update(*v1alpha1.Content) (*v1alpha1.Content, error)

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

type ContentController 

type ContentController interface {
	generic.ControllerMeta
	ContentClient

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

	Cache() ContentCache
}

func NewContentController 

func NewContentController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ContentController

type ContentHandler 

type ContentHandler func(string, *v1alpha1.Content) (*v1alpha1.Content, error)

type ContentIndexer 

type ContentIndexer func(obj *v1alpha1.Content) ([]string, error)

type GitRepoCache added in v0.3.0 

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

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

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

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

type GitRepoGeneratingHandler added in v0.3.0 

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

type GitRepoHandler added in v0.3.0 

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

type GitRepoIndexer added in v0.3.0 

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

type GitRepoRestrictionCache added in v0.3.0 

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

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

type GitRepoRestrictionClient added in v0.3.0 

type GitRepoRestrictionClient interface {
	Create(*v1alpha1.GitRepoRestriction) (*v1alpha1.GitRepoRestriction, error)
	Update(*v1alpha1.GitRepoRestriction) (*v1alpha1.GitRepoRestriction, error)

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

type GitRepoRestrictionController added in v0.3.0 

type GitRepoRestrictionController interface {
	generic.ControllerMeta
	GitRepoRestrictionClient

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

	Cache() GitRepoRestrictionCache
}

func NewGitRepoRestrictionController added in v0.3.0 

func NewGitRepoRestrictionController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) GitRepoRestrictionController

type GitRepoRestrictionHandler added in v0.3.0 

type GitRepoRestrictionHandler func(string, *v1alpha1.GitRepoRestriction) (*v1alpha1.GitRepoRestriction, error)

type GitRepoRestrictionIndexer added in v0.3.0 

type GitRepoRestrictionIndexer func(obj *v1alpha1.GitRepoRestriction) ([]string, error)

type GitRepoStatusHandler added in v0.3.0 

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

type Interface 

type Interface interface {
	Bundle() BundleController
	BundleDeployment() BundleDeploymentController
	BundleNamespaceMapping() BundleNamespaceMappingController
	Cluster() ClusterController
	ClusterGroup() ClusterGroupController
	ClusterRegistration() ClusterRegistrationController
	ClusterRegistrationToken() ClusterRegistrationTokenController
	Content() ContentController
	GitRepo() GitRepoController
	GitRepoRestriction() GitRepoRestrictionController
}

func New 

func New(controllerFactory controller.SharedControllerFactory) Interface

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.