v1alpha1

package
v0.8.6 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2024 License: Apache-2.0 Imports: 21 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 FromImageScanHandlerToHandler added in v0.3.6 

func FromImageScanHandlerToHandler(sync ImageScanHandler) generic.Handler

func RegisterBundleDeploymentGeneratingHandler 

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

RegisterBundleDeploymentGeneratingHandler configures a BundleDeploymentController to execute a BundleDeploymentGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterBundleDeploymentStatusHandler 

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

RegisterBundleDeploymentStatusHandler configures a BundleDeploymentController to execute a BundleDeploymentStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterBundleGeneratingHandler 

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

RegisterBundleGeneratingHandler configures a BundleController to execute a BundleGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterBundleStatusHandler 

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

RegisterBundleStatusHandler configures a BundleController to execute a BundleStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterGeneratingHandler 

func RegisterClusterGeneratingHandler(ctx context.Context, controller ClusterController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterClusterGeneratingHandler configures a ClusterController to execute a ClusterGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterGroupGeneratingHandler 

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

RegisterClusterGroupGeneratingHandler configures a ClusterGroupController to execute a ClusterGroupGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterGroupStatusHandler 

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

RegisterClusterGroupStatusHandler configures a ClusterGroupController to execute a ClusterGroupStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

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)

RegisterClusterRegistrationGeneratingHandler configures a ClusterRegistrationController to execute a ClusterRegistrationGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterRegistrationStatusHandler added in v0.3.0 

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

RegisterClusterRegistrationStatusHandler configures a ClusterRegistrationController to execute a ClusterRegistrationStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

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)

RegisterClusterRegistrationTokenGeneratingHandler configures a ClusterRegistrationTokenController to execute a ClusterRegistrationTokenGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterRegistrationTokenStatusHandler added in v0.3.0 

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

RegisterClusterRegistrationTokenStatusHandler configures a ClusterRegistrationTokenController to execute a ClusterRegistrationTokenStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterStatusHandler 

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

RegisterClusterStatusHandler configures a ClusterController to execute a ClusterStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

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)

RegisterGitRepoGeneratingHandler configures a GitRepoController to execute a GitRepoGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterGitRepoStatusHandler added in v0.3.0 

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

RegisterGitRepoStatusHandler configures a GitRepoController to execute a GitRepoStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterImageScanGeneratingHandler added in v0.3.6 

func RegisterImageScanGeneratingHandler(ctx context.Context, controller ImageScanController, apply apply.Apply,
	condition condition.Cond, name string, handler ImageScanGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterImageScanGeneratingHandler configures a ImageScanController to execute a ImageScanGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterImageScanStatusHandler added in v0.3.6 

func RegisterImageScanStatusHandler(ctx context.Context, controller ImageScanController, condition condition.Cond, name string, handler ImageScanStatusHandler)

RegisterImageScanStatusHandler configures a ImageScanController to execute a ImageScanStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

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)

func UpdateImageScanDeepCopyOnChange added in v0.3.6 

func UpdateImageScanDeepCopyOnChange(client ImageScanClient, obj *v1alpha1.ImageScan, handler func(obj *v1alpha1.ImageScan) (*v1alpha1.ImageScan, error)) (*v1alpha1.ImageScan, 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)

BundleDeploymentGeneratingHandler is the top-level handler that is executed for every BundleDeployment event. It extends BundleDeploymentStatusHandler by a returning a slice of child objects to be passed to apply.Apply

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)

BundleDeploymentStatusHandler is executed for every added or modified BundleDeployment. Should return the new status to be updated

type BundleGeneratingHandler 

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

BundleGeneratingHandler is the top-level handler that is executed for every Bundle event. It extends BundleStatusHandler by a returning a slice of child objects to be passed to apply.Apply

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)

BundleStatusHandler is executed for every added or modified Bundle. Should return the new status to be updated

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)

ClusterGeneratingHandler is the top-level handler that is executed for every Cluster event. It extends ClusterStatusHandler by a returning a slice of child objects to be passed to apply.Apply

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)

ClusterGroupGeneratingHandler is the top-level handler that is executed for every ClusterGroup event. It extends ClusterGroupStatusHandler by a returning a slice of child objects to be passed to apply.Apply

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)

ClusterGroupStatusHandler is executed for every added or modified ClusterGroup. Should return the new status to be updated

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)

ClusterRegistrationGeneratingHandler is the top-level handler that is executed for every ClusterRegistration event. It extends ClusterRegistrationStatusHandler by a returning a slice of child objects to be passed to apply.Apply

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)

ClusterRegistrationStatusHandler is executed for every added or modified ClusterRegistration. Should return the new status to be updated

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)

ClusterRegistrationTokenGeneratingHandler is the top-level handler that is executed for every ClusterRegistrationToken event. It extends ClusterRegistrationTokenStatusHandler by a returning a slice of child objects to be passed to apply.Apply

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)

ClusterRegistrationTokenStatusHandler is executed for every added or modified ClusterRegistrationToken. Should return the new status to be updated

type ClusterStatusHandler 

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

ClusterStatusHandler is executed for every added or modified Cluster. Should return the new status to be updated

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)

GitRepoGeneratingHandler is the top-level handler that is executed for every GitRepo event. It extends GitRepoStatusHandler by a returning a slice of child objects to be passed to apply.Apply

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)

GitRepoStatusHandler is executed for every added or modified GitRepo. Should return the new status to be updated

type ImageScanCache added in v0.3.6 

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

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

type ImageScanClient added in v0.3.6 

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

type ImageScanController added in v0.3.6 

type ImageScanController interface {
	generic.ControllerMeta
	ImageScanClient

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

	Cache() ImageScanCache
}

func NewImageScanController added in v0.3.6 

func NewImageScanController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ImageScanController

type ImageScanGeneratingHandler added in v0.3.6 

type ImageScanGeneratingHandler func(obj *v1alpha1.ImageScan, status v1alpha1.ImageScanStatus) ([]runtime.Object, v1alpha1.ImageScanStatus, error)

ImageScanGeneratingHandler is the top-level handler that is executed for every ImageScan event. It extends ImageScanStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type ImageScanHandler added in v0.3.6 

type ImageScanHandler func(string, *v1alpha1.ImageScan) (*v1alpha1.ImageScan, error)

type ImageScanIndexer added in v0.3.6 

type ImageScanIndexer func(obj *v1alpha1.ImageScan) ([]string, error)

type ImageScanStatusHandler added in v0.3.6 

type ImageScanStatusHandler func(obj *v1alpha1.ImageScan, status v1alpha1.ImageScanStatus) (v1alpha1.ImageScanStatus, error)

ImageScanStatusHandler is executed for every added or modified ImageScan. Should return the new status to be updated

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
	ImageScan() ImageScanController
}

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.