v1alpha1

package
v0.1.1-alpha1 Latest Latest
Warning

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

Go to latest
Published: Apr 9, 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 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 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 UpdateBundleDeepCopyOnChange

func UpdateBundleDeepCopyOnChange(client BundleClient, obj *v1alpha1.Bundle, handler func(obj *v1alpha1.Bundle) (*v1alpha1.Bundle, error)) (*v1alpha1.Bundle, 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 UpdateContentDeepCopyOnChange

func UpdateContentDeepCopyOnChange(client ContentClient, obj *v1alpha1.Content, handler func(obj *v1alpha1.Content) (*v1alpha1.Content, error)) (*v1alpha1.Content, 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, 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
}

type BundleDeploymentIndexer

type BundleDeploymentIndexer func(obj *v1alpha1.BundleDeployment) ([]string, 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 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, 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
}

type ClusterGroupHandler

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

type ClusterGroupIndexer

type ClusterGroupIndexer func(obj *v1alpha1.ClusterGroup) ([]string, 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
}

type ClusterGroupTokenIndexer

type ClusterGroupTokenIndexer func(obj *v1alpha1.ClusterGroupToken) ([]string, error)

type ClusterHandler

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

type ClusterIndexer

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

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 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
}

type ClusterRegistrationRequestIndexer

type ClusterRegistrationRequestIndexer func(obj *v1alpha1.ClusterRegistrationRequest) ([]string, 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, controllerManager *generic.ControllerManager, clientGetter clientset.ContentsGetter, informer informers.ContentInformer) ContentController

type ContentHandler

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

type ContentIndexer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL