Versions in this module Expand all Collapse all v0 v0.0.2 Mar 25, 2024 v0.0.1 Jan 11, 2024 Changes in this version + var ErrSkip = controller.ErrIgnore + func ConfigureApplyForObject(apply apply.Apply, obj metav1.Object, opts *GeneratingHandlerOptions) apply.Apply + type Cache struct + func (c *Cache[T]) AddIndexer(indexName string, indexer Indexer[T]) + func (c *Cache[T]) Get(namespace, name string) (T, error) + func (c *Cache[T]) GetByIndex(indexName, key string) (result []T, err error) + func (c *Cache[T]) List(namespace string, selector labels.Selector) (ret []T, err error) + type CacheInterface interface + AddIndexer func(indexName string, indexer Indexer[T]) + Get func(namespace, name string) (T, error) + GetByIndex func(indexName, key string) ([]T, error) + List func(namespace string, selector labels.Selector) ([]T, error) + type ClientInterface interface + Create func(T) (T, error) + Delete func(namespace, name string, options *metav1.DeleteOptions) error + Get func(namespace, name string, options metav1.GetOptions) (T, error) + List func(namespace string, opts metav1.ListOptions) (TList, error) + Patch func(namespace, name string, pt types.PatchType, data []byte, ...) (result T, err error) + Update func(T) (T, error) + UpdateStatus func(T) (T, error) + Watch func(namespace string, opts metav1.ListOptions) (watch.Interface, error) + WithImpersonation func(impersonate rest.ImpersonationConfig) (ClientInterface[T, TList], error) + type Controller struct + func NewController[T RuntimeMetaObject, TList runtime.Object](gvk schema.GroupVersionKind, resource string, namespaced bool, ...) *Controller[T, TList] + func (c *Controller[T, TList]) AddGenericHandler(ctx context.Context, name string, handler Handler) + func (c *Controller[T, TList]) AddGenericRemoveHandler(ctx context.Context, name string, handler Handler) + func (c *Controller[T, TList]) Cache() CacheInterface[T] + func (c *Controller[T, TList]) Create(obj T) (T, error) + func (c *Controller[T, TList]) Delete(namespace, name string, options *metav1.DeleteOptions) error + func (c *Controller[T, TList]) Enqueue(namespace, name string) + func (c *Controller[T, TList]) EnqueueAfter(namespace, name string, duration time.Duration) + func (c *Controller[T, TList]) Get(namespace, name string, options metav1.GetOptions) (T, error) + func (c *Controller[T, TList]) GroupVersionKind() schema.GroupVersionKind + func (c *Controller[T, TList]) Informer() cache.SharedIndexInformer + func (c *Controller[T, TList]) List(namespace string, opts metav1.ListOptions) (TList, error) + func (c *Controller[T, TList]) OnChange(ctx context.Context, name string, sync ObjectHandler[T]) + func (c *Controller[T, TList]) OnRemove(ctx context.Context, name string, sync ObjectHandler[T]) + func (c *Controller[T, TList]) Patch(namespace, name string, pt types.PatchType, data []byte, ...) (T, error) + func (c *Controller[T, TList]) Update(obj T) (T, error) + func (c *Controller[T, TList]) UpdateStatus(obj T) (T, error) + func (c *Controller[T, TList]) Updater() Updater + func (c *Controller[T, TList]) Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error) + func (c *Controller[T, TList]) WithImpersonation(impersonate rest.ImpersonationConfig) (ClientInterface[T, TList], error) + type ControllerInterface interface + Cache func() CacheInterface[T] + Enqueue func(namespace, name string) + EnqueueAfter func(namespace, name string, duration time.Duration) + OnChange func(ctx context.Context, name string, sync ObjectHandler[T]) + OnRemove func(ctx context.Context, name string, sync ObjectHandler[T]) + type ControllerMeta interface + AddGenericHandler func(ctx context.Context, name string, handler Handler) + AddGenericRemoveHandler func(ctx context.Context, name string, handler Handler) + GroupVersionKind func() schema.GroupVersionKind + Informer func() cache.SharedIndexInformer + Updater func() Updater + type Factory struct + func NewFactoryFromConfigWithOptions(config *rest.Config, opts *FactoryOptions) (*Factory, error) + func (c *Factory) ControllerFactory() controller.SharedControllerFactory + func (c *Factory) SetThreadiness(gvk schema.GroupVersionKind, threadiness int) + func (c *Factory) Start(ctx context.Context, defaultThreadiness int) error + func (c *Factory) Sync(ctx context.Context) error + type FactoryOptions struct + HealthCallback func(bool) + Namespace string + Resync time.Duration + SharedCacheFactory cache.SharedCacheFactory + SharedControllerFactory controller.SharedControllerFactory + type GeneratingHandlerOptions struct + AllowClusterScoped bool + AllowCrossNamespace bool + DynamicLookup bool + NoOwnerReference bool + UniqueApplyForResourceVersion bool + type Handler func(key string, obj runtime.Object) (runtime.Object, error) + func FromObjectHandlerToHandler[T RuntimeMetaObject](sync ObjectHandler[T]) Handler + func NewRemoveHandler(name string, updater Updater, handler Handler) Handler + type Indexer func(obj T) ([]string, error) + type NonNamespacedCache struct + func (c *NonNamespacedCache[T]) Get(name string) (T, error) + func (c *NonNamespacedCache[T]) List(selector labels.Selector) (ret []T, err error) + type NonNamespacedCacheInterface interface + AddIndexer func(indexName string, indexer Indexer[T]) + Get func(name string) (T, error) + GetByIndex func(indexName, key string) ([]T, error) + List func(selector labels.Selector) ([]T, error) + type NonNamespacedClientInterface interface + Create func(T) (T, error) + Delete func(name string, options *metav1.DeleteOptions) error + Get func(name string, options metav1.GetOptions) (T, error) + List func(opts metav1.ListOptions) (TList, error) + Patch func(name string, pt types.PatchType, data []byte, subresources ...string) (result T, err error) + Update func(T) (T, error) + UpdateStatus func(T) (T, error) + Watch func(opts metav1.ListOptions) (watch.Interface, error) + WithImpersonation func(impersonate rest.ImpersonationConfig) (NonNamespacedClientInterface[T, TList], error) + type NonNamespacedController struct + func NewNonNamespacedController[T RuntimeMetaObject, TList runtime.Object](gvk schema.GroupVersionKind, resource string, ...) *NonNamespacedController[T, TList] + func (c *NonNamespacedController[T, TList]) Cache() NonNamespacedCacheInterface[T] + func (c *NonNamespacedController[T, TList]) Delete(name string, options *metav1.DeleteOptions) error + func (c *NonNamespacedController[T, TList]) Enqueue(name string) + func (c *NonNamespacedController[T, TList]) EnqueueAfter(name string, duration time.Duration) + func (c *NonNamespacedController[T, TList]) Get(name string, options metav1.GetOptions) (T, error) + func (c *NonNamespacedController[T, TList]) List(opts metav1.ListOptions) (TList, error) + func (c *NonNamespacedController[T, TList]) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (T, error) + func (c *NonNamespacedController[T, TList]) Watch(opts metav1.ListOptions) (watch.Interface, error) + func (c *NonNamespacedController[T, TList]) WithImpersonation(impersonate rest.ImpersonationConfig) (NonNamespacedClientInterface[T, TList], error) + type NonNamespacedControllerInterface interface + Cache func() NonNamespacedCacheInterface[T] + Enqueue func(name string) + EnqueueAfter func(name string, duration time.Duration) + OnChange func(ctx context.Context, name string, sync ObjectHandler[T]) + OnRemove func(ctx context.Context, name string, sync ObjectHandler[T]) + type ObjectHandler func(string, T) (T, error) + type RuntimeMetaObject interface + type Updater func(runtime.Object) (runtime.Object, error)
Go to main page