Documentation ¶
Index ¶
- func FromBundleDeploymentHandlerToHandler(sync BundleDeploymentHandler) generic.Handler
- func FromBundleHandlerToHandler(sync BundleHandler) generic.Handler
- func FromClusterGroupHandlerToHandler(sync ClusterGroupHandler) generic.Handler
- func FromClusterGroupTokenHandlerToHandler(sync ClusterGroupTokenHandler) generic.Handler
- func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler
- func FromClusterRegistrationRequestHandlerToHandler(sync ClusterRegistrationRequestHandler) generic.Handler
- func FromContentHandlerToHandler(sync ContentHandler) generic.Handler
- func RegisterBundleDeploymentGeneratingHandler(ctx context.Context, controller BundleDeploymentController, apply apply.Apply, ...)
- func RegisterBundleDeploymentStatusHandler(ctx context.Context, controller BundleDeploymentController, ...)
- func RegisterBundleGeneratingHandler(ctx context.Context, controller BundleController, apply apply.Apply, ...)
- func RegisterBundleStatusHandler(ctx context.Context, controller BundleController, condition condition.Cond, ...)
- 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 RegisterClusterGroupTokenGeneratingHandler(ctx context.Context, controller ClusterGroupTokenController, apply apply.Apply, ...)
- func RegisterClusterGroupTokenStatusHandler(ctx context.Context, controller ClusterGroupTokenController, ...)
- func RegisterClusterRegistrationRequestGeneratingHandler(ctx context.Context, controller ClusterRegistrationRequestController, ...)
- func RegisterClusterRegistrationRequestStatusHandler(ctx context.Context, controller ClusterRegistrationRequestController, ...)
- func RegisterClusterStatusHandler(ctx context.Context, controller ClusterController, condition condition.Cond, ...)
- func UpdateBundleDeepCopyOnChange(client BundleClient, obj *v1alpha1.Bundle, ...) (*v1alpha1.Bundle, error)
- func UpdateBundleDeploymentDeepCopyOnChange(client BundleDeploymentClient, obj *v1alpha1.BundleDeployment, ...) (*v1alpha1.BundleDeployment, error)
- func UpdateClusterDeepCopyOnChange(client ClusterClient, obj *v1alpha1.Cluster, ...) (*v1alpha1.Cluster, error)
- func UpdateClusterGroupDeepCopyOnChange(client ClusterGroupClient, obj *v1alpha1.ClusterGroup, ...) (*v1alpha1.ClusterGroup, error)
- func UpdateClusterGroupTokenDeepCopyOnChange(client ClusterGroupTokenClient, obj *v1alpha1.ClusterGroupToken, ...) (*v1alpha1.ClusterGroupToken, error)
- func UpdateClusterRegistrationRequestDeepCopyOnChange(client ClusterRegistrationRequestClient, ...) (*v1alpha1.ClusterRegistrationRequest, error)
- func UpdateContentDeepCopyOnChange(client ContentClient, obj *v1alpha1.Content, ...) (*v1alpha1.Content, error)
- type BundleCache
- type BundleClient
- type BundleController
- type BundleDeploymentCache
- type BundleDeploymentClient
- type BundleDeploymentController
- type BundleDeploymentGeneratingHandler
- type BundleDeploymentHandler
- type BundleDeploymentIndexer
- type BundleDeploymentStatusHandler
- type BundleGeneratingHandler
- type BundleHandler
- type BundleIndexer
- type BundleStatusHandler
- type ClusterCache
- type ClusterClient
- type ClusterController
- type ClusterGeneratingHandler
- type ClusterGroupCache
- type ClusterGroupClient
- type ClusterGroupController
- type ClusterGroupGeneratingHandler
- type ClusterGroupHandler
- type ClusterGroupIndexer
- type ClusterGroupStatusHandler
- type ClusterGroupTokenCache
- type ClusterGroupTokenClient
- type ClusterGroupTokenController
- type ClusterGroupTokenGeneratingHandler
- type ClusterGroupTokenHandler
- type ClusterGroupTokenIndexer
- type ClusterGroupTokenStatusHandler
- type ClusterHandler
- type ClusterIndexer
- type ClusterRegistrationRequestCache
- type ClusterRegistrationRequestClient
- type ClusterRegistrationRequestController
- type ClusterRegistrationRequestGeneratingHandler
- type ClusterRegistrationRequestHandler
- type ClusterRegistrationRequestIndexer
- type ClusterRegistrationRequestStatusHandler
- type ClusterStatusHandler
- type ContentCache
- type ContentClient
- type ContentController
- type ContentHandler
- type ContentIndexer
- type Interface
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 FromClusterGroupHandlerToHandler ¶
func FromClusterGroupHandlerToHandler(sync ClusterGroupHandler) generic.Handler
func FromClusterGroupTokenHandlerToHandler ¶
func FromClusterGroupTokenHandlerToHandler(sync ClusterGroupTokenHandler) generic.Handler
func FromClusterHandlerToHandler ¶
func FromClusterHandlerToHandler(sync ClusterHandler) generic.Handler
func FromClusterRegistrationRequestHandlerToHandler ¶
func FromClusterRegistrationRequestHandlerToHandler(sync ClusterRegistrationRequestHandler) generic.Handler
func FromContentHandlerToHandler ¶
func FromContentHandlerToHandler(sync ContentHandler) 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 RegisterClusterGroupTokenGeneratingHandler ¶
func RegisterClusterGroupTokenGeneratingHandler(ctx context.Context, controller ClusterGroupTokenController, apply apply.Apply, condition condition.Cond, name string, handler ClusterGroupTokenGeneratingHandler, opts *generic.GeneratingHandlerOptions)
func RegisterClusterGroupTokenStatusHandler ¶
func RegisterClusterGroupTokenStatusHandler(ctx context.Context, controller ClusterGroupTokenController, condition condition.Cond, name string, handler ClusterGroupTokenStatusHandler)
func RegisterClusterRegistrationRequestGeneratingHandler ¶
func RegisterClusterRegistrationRequestGeneratingHandler(ctx context.Context, controller ClusterRegistrationRequestController, apply apply.Apply, condition condition.Cond, name string, handler ClusterRegistrationRequestGeneratingHandler, opts *generic.GeneratingHandlerOptions)
func RegisterClusterRegistrationRequestStatusHandler ¶
func RegisterClusterRegistrationRequestStatusHandler(ctx context.Context, controller ClusterRegistrationRequestController, condition condition.Cond, name string, handler ClusterRegistrationRequestStatusHandler)
func RegisterClusterStatusHandler ¶
func RegisterClusterStatusHandler(ctx context.Context, controller ClusterController, condition condition.Cond, name string, handler ClusterStatusHandler)
func UpdateBundleDeploymentDeepCopyOnChange ¶
func UpdateBundleDeploymentDeepCopyOnChange(client BundleDeploymentClient, obj *v1alpha1.BundleDeployment, handler func(obj *v1alpha1.BundleDeployment) (*v1alpha1.BundleDeployment, error)) (*v1alpha1.BundleDeployment, error)
func UpdateClusterGroupDeepCopyOnChange ¶
func UpdateClusterGroupDeepCopyOnChange(client ClusterGroupClient, obj *v1alpha1.ClusterGroup, handler func(obj *v1alpha1.ClusterGroup) (*v1alpha1.ClusterGroup, error)) (*v1alpha1.ClusterGroup, error)
func UpdateClusterGroupTokenDeepCopyOnChange ¶
func UpdateClusterGroupTokenDeepCopyOnChange(client ClusterGroupTokenClient, obj *v1alpha1.ClusterGroupToken, handler func(obj *v1alpha1.ClusterGroupToken) (*v1alpha1.ClusterGroupToken, error)) (*v1alpha1.ClusterGroupToken, error)
func UpdateClusterRegistrationRequestDeepCopyOnChange ¶
func UpdateClusterRegistrationRequestDeepCopyOnChange(client ClusterRegistrationRequestClient, obj *v1alpha1.ClusterRegistrationRequest, handler func(obj *v1alpha1.ClusterRegistrationRequest) (*v1alpha1.ClusterRegistrationRequest, error)) (*v1alpha1.ClusterRegistrationRequest, error)
Types ¶
type BundleCache ¶
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, controllerManager *generic.ControllerManager, clientGetter clientset.BundlesGetter, informer informers.BundleInformer) 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, controllerManager *generic.ControllerManager, clientGetter clientset.BundleDeploymentsGetter, informer informers.BundleDeploymentInformer) 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 BundleStatusHandler ¶
type BundleStatusHandler func(obj *v1alpha1.Bundle, status v1alpha1.BundleStatus) (v1alpha1.BundleStatus, error)
type ClusterCache ¶
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, controllerManager *generic.ControllerManager, clientGetter clientset.ClustersGetter, informer informers.ClusterInformer) 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, controllerManager *generic.ControllerManager, clientGetter clientset.ClusterGroupsGetter, informer informers.ClusterGroupInformer) 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 ClusterGroupTokenCache ¶
type ClusterGroupTokenCache interface { Get(namespace, name string) (*v1alpha1.ClusterGroupToken, error) List(namespace string, selector labels.Selector) ([]*v1alpha1.ClusterGroupToken, error) AddIndexer(indexName string, indexer ClusterGroupTokenIndexer) GetByIndex(indexName, key string) ([]*v1alpha1.ClusterGroupToken, error) }
type ClusterGroupTokenClient ¶
type ClusterGroupTokenClient interface { Create(*v1alpha1.ClusterGroupToken) (*v1alpha1.ClusterGroupToken, error) Update(*v1alpha1.ClusterGroupToken) (*v1alpha1.ClusterGroupToken, error) UpdateStatus(*v1alpha1.ClusterGroupToken) (*v1alpha1.ClusterGroupToken, error) Delete(namespace, name string, options *metav1.DeleteOptions) error Get(namespace, name string, options metav1.GetOptions) (*v1alpha1.ClusterGroupToken, error) List(namespace string, opts metav1.ListOptions) (*v1alpha1.ClusterGroupTokenList, error) Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error) Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.ClusterGroupToken, err error) }
type ClusterGroupTokenController ¶
type ClusterGroupTokenController interface { generic.ControllerMeta ClusterGroupTokenClient OnChange(ctx context.Context, name string, sync ClusterGroupTokenHandler) OnRemove(ctx context.Context, name string, sync ClusterGroupTokenHandler) Enqueue(namespace, name string) EnqueueAfter(namespace, name string, duration time.Duration) Cache() ClusterGroupTokenCache }
func NewClusterGroupTokenController ¶
func NewClusterGroupTokenController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ClusterGroupTokensGetter, informer informers.ClusterGroupTokenInformer) ClusterGroupTokenController
type ClusterGroupTokenGeneratingHandler ¶
type ClusterGroupTokenGeneratingHandler func(obj *v1alpha1.ClusterGroupToken, status v1alpha1.ClusterGroupTokenStatus) ([]runtime.Object, v1alpha1.ClusterGroupTokenStatus, error)
type ClusterGroupTokenHandler ¶
type ClusterGroupTokenHandler func(string, *v1alpha1.ClusterGroupToken) (*v1alpha1.ClusterGroupToken, error)
type ClusterGroupTokenIndexer ¶
type ClusterGroupTokenIndexer func(obj *v1alpha1.ClusterGroupToken) ([]string, error)
type ClusterGroupTokenStatusHandler ¶
type ClusterGroupTokenStatusHandler func(obj *v1alpha1.ClusterGroupToken, status v1alpha1.ClusterGroupTokenStatus) (v1alpha1.ClusterGroupTokenStatus, error)
type ClusterHandler ¶
type ClusterRegistrationRequestCache ¶
type ClusterRegistrationRequestCache interface { Get(namespace, name string) (*v1alpha1.ClusterRegistrationRequest, error) List(namespace string, selector labels.Selector) ([]*v1alpha1.ClusterRegistrationRequest, error) AddIndexer(indexName string, indexer ClusterRegistrationRequestIndexer) GetByIndex(indexName, key string) ([]*v1alpha1.ClusterRegistrationRequest, error) }
type ClusterRegistrationRequestClient ¶
type ClusterRegistrationRequestClient interface { Create(*v1alpha1.ClusterRegistrationRequest) (*v1alpha1.ClusterRegistrationRequest, error) Update(*v1alpha1.ClusterRegistrationRequest) (*v1alpha1.ClusterRegistrationRequest, error) UpdateStatus(*v1alpha1.ClusterRegistrationRequest) (*v1alpha1.ClusterRegistrationRequest, error) Delete(namespace, name string, options *metav1.DeleteOptions) error Get(namespace, name string, options metav1.GetOptions) (*v1alpha1.ClusterRegistrationRequest, error) List(namespace string, opts metav1.ListOptions) (*v1alpha1.ClusterRegistrationRequestList, error) Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error) Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.ClusterRegistrationRequest, err error) }
type ClusterRegistrationRequestController ¶
type ClusterRegistrationRequestController interface { generic.ControllerMeta ClusterRegistrationRequestClient OnChange(ctx context.Context, name string, sync ClusterRegistrationRequestHandler) OnRemove(ctx context.Context, name string, sync ClusterRegistrationRequestHandler) Enqueue(namespace, name string) EnqueueAfter(namespace, name string, duration time.Duration) Cache() ClusterRegistrationRequestCache }
func NewClusterRegistrationRequestController ¶
func NewClusterRegistrationRequestController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ClusterRegistrationRequestsGetter, informer informers.ClusterRegistrationRequestInformer) ClusterRegistrationRequestController
type ClusterRegistrationRequestGeneratingHandler ¶
type ClusterRegistrationRequestGeneratingHandler func(obj *v1alpha1.ClusterRegistrationRequest, status v1alpha1.ClusterRegistrationRequestStatus) ([]runtime.Object, v1alpha1.ClusterRegistrationRequestStatus, error)
type ClusterRegistrationRequestHandler ¶
type ClusterRegistrationRequestHandler func(string, *v1alpha1.ClusterRegistrationRequest) (*v1alpha1.ClusterRegistrationRequest, error)
type ClusterRegistrationRequestIndexer ¶
type ClusterRegistrationRequestIndexer func(obj *v1alpha1.ClusterRegistrationRequest) ([]string, error)
type ClusterRegistrationRequestStatusHandler ¶
type ClusterRegistrationRequestStatusHandler func(obj *v1alpha1.ClusterRegistrationRequest, status v1alpha1.ClusterRegistrationRequestStatus) (v1alpha1.ClusterRegistrationRequestStatus, error)
type ClusterStatusHandler ¶
type ClusterStatusHandler func(obj *v1alpha1.Cluster, status v1alpha1.ClusterStatus) (v1alpha1.ClusterStatus, error)
type ContentCache ¶
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, controllerManager *generic.ControllerManager, clientGetter clientset.ContentsGetter, informer informers.ContentInformer) ContentController
type ContentHandler ¶
type Interface ¶
type Interface interface { Bundle() BundleController BundleDeployment() BundleDeploymentController Cluster() ClusterController ClusterGroup() ClusterGroupController ClusterGroupToken() ClusterGroupTokenController ClusterRegistrationRequest() ClusterRegistrationRequestController Content() ContentController }
func New ¶
func New(controllerManager *generic.ControllerManager, client clientset.FleetV1alpha1Interface, informers informers.Interface) Interface
Click to show internal directories.
Click to hide internal directories.