Versions in this module Expand all Collapse all v0 v0.1.1 Sep 20, 2025 v0.1.0 Sep 4, 2025 Changes in this version + const DefaultWatchChannelBuffer + func AppendToListItem(list client.ObjectList, obj client.Object) + func NewViewObjectList(operator, view string) object.ObjectList + type APIClient struct + Cache cache.Cache + Client client.Client + Discovery discovery.DiscoveryInterface + Log logr.Logger + RESTMapper meta.RESTMapper + func NewCompositeAPIClient(config *rest.Config, opts Options) (*APIClient, error) + func (c *APIClient) GetCache() *CompositeCache + func (c *APIClient) GetClient() *CompositeClient + func (c *APIClient) GetDiscovery() *CompositeDiscoveryClient + type CacheOptions struct + DefaultCache cache.Cache + Logger logr.Logger + type ClientMultiplexer interface + RegisterClient func(group string, client client.Client) error + UnregisterClient func(group string) error + func NewClientMultiplexer(logger logr.Logger) ClientMultiplexer + type ClientOptions = client.Options + type CompositeCache struct + func NewCompositeCache(config *rest.Config, opts CacheOptions) (*CompositeCache, error) + func (cc *CompositeCache) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error + func (cc *CompositeCache) GetDefaultCache() cache.Cache + func (cc *CompositeCache) GetInformer(ctx context.Context, obj client.Object, opts ...cache.InformerGetOption) (cache.Informer, error) + func (cc *CompositeCache) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, ...) (cache.Informer, error) + func (cc *CompositeCache) GetLogger() logr.Logger + func (cc *CompositeCache) GetViewCache() *ViewCache + func (cc *CompositeCache) IndexField(ctx context.Context, obj client.Object, field string, ...) error + func (cc *CompositeCache) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error + func (cc *CompositeCache) RemoveInformer(ctx context.Context, obj client.Object) error + func (cc *CompositeCache) Start(ctx context.Context) error + func (cc *CompositeCache) WaitForCacheSync(ctx context.Context) bool + type CompositeClient struct + func NewCompositeClient(config *rest.Config, options ClientOptions) (*CompositeClient, error) + func (c *CompositeClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error + func (c *CompositeClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error + func (c *CompositeClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error + func (c *CompositeClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error + func (c *CompositeClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error + func (c *CompositeClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error + func (c *CompositeClient) SetCache(cache cache.Cache) + func (c *CompositeClient) SetClient(client client.Client) + func (c *CompositeClient) Status() client.SubResourceWriter + func (c *CompositeClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error + func (c *CompositeClient) Watch(ctx context.Context, list client.ObjectList, opts ...client.ListOption) (watch.Interface, error) + type CompositeDiscoveryClient struct + func NewCompositeDiscoveryClient(nativeDiscovery discovery.DiscoveryInterface) *CompositeDiscoveryClient + func (c *CompositeDiscoveryClient) OpenAPISchema() (*openapiv2.Document, error) + func (c *CompositeDiscoveryClient) OpenAPIV3() openapi.Client + func (c *CompositeDiscoveryClient) RESTClient() restclient.Interface + func (c *CompositeDiscoveryClient) ServerGroups() (*metav1.APIGroupList, error) + func (c *CompositeDiscoveryClient) ServerGroupsAndResources() ([]*metav1.APIGroup, []*metav1.APIResourceList, error) + func (c *CompositeDiscoveryClient) ServerPreferredNamespacedResources() ([]*metav1.APIResourceList, error) + func (c *CompositeDiscoveryClient) ServerPreferredResources() ([]*metav1.APIResourceList, error) + func (c *CompositeDiscoveryClient) ServerResourcesForGroupVersion(groupVersion string) (*metav1.APIResourceList, error) + func (c *CompositeDiscoveryClient) ServerVersion() (*version.Info, error) + func (c *CompositeDiscoveryClient) WithLegacy() discovery.DiscoveryInterface + type CompositeRESTMapper struct + func NewCompositeRESTMapper(compositeDiscovery discovery.DiscoveryInterface) *CompositeRESTMapper + func (m *CompositeRESTMapper) KindFor(resource schema.GroupVersionResource) (schema.GroupVersionKind, error) + func (m *CompositeRESTMapper) KindsFor(resource schema.GroupVersionResource) ([]schema.GroupVersionKind, error) + func (m *CompositeRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error) + func (m *CompositeRESTMapper) RESTMappings(gk schema.GroupKind, versions ...string) ([]*meta.RESTMapping, error) + func (m *CompositeRESTMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error) + func (m *CompositeRESTMapper) ResourceSingularizer(resource string) (string, error) + func (m *CompositeRESTMapper) ResourcesFor(input schema.GroupVersionResource) ([]schema.GroupVersionResource, error) + type FakeInformer struct + Indexer Lister + RunCount int + Synced bool + func (f *FakeInformer) Add(obj metav1.Object) + func (f *FakeInformer) AddEventHandler(handler toolscache.ResourceEventHandler) (toolscache.ResourceEventHandlerRegistration, error) + func (f *FakeInformer) AddEventHandlerWithContext(handler toolscache.ResourceEventHandler, _ time.Duration) (toolscache.ResourceEventHandlerRegistration, error) + func (f *FakeInformer) AddEventHandlerWithOptions(handler toolscache.ResourceEventHandler, _ toolscache.HandlerOptions) (toolscache.ResourceEventHandlerRegistration, error) + func (f *FakeInformer) AddEventHandlerWithResyncPeriod(handler toolscache.ResourceEventHandler, _ time.Duration) (toolscache.ResourceEventHandlerRegistration, error) + func (f *FakeInformer) AddIndexers(indexers toolscache.Indexers) error + func (f *FakeInformer) Delete(obj metav1.Object) + func (f *FakeInformer) GetController() toolscache.Controller + func (f *FakeInformer) GetIndexer() toolscache.Indexer + func (f *FakeInformer) GetStore() toolscache.Store + func (f *FakeInformer) HasSynced() bool + func (f *FakeInformer) Informer() toolscache.SharedIndexInformer + func (f *FakeInformer) IsStopped() bool + func (f *FakeInformer) LastSyncResourceVersion() string + func (f *FakeInformer) RemoveEventHandler(handle toolscache.ResourceEventHandlerRegistration) error + func (f *FakeInformer) Run(<-chan struct{}) + func (f *FakeInformer) RunWithContext(_ context.Context) + func (f *FakeInformer) SetTransform(t toolscache.TransformFunc) error + func (f *FakeInformer) SetWatchErrorHandler(toolscache.WatchErrorHandler) error + func (f *FakeInformer) SetWatchErrorHandlerWithContext(toolscache.WatchErrorHandlerWithContext) error + func (f *FakeInformer) Update(oldObj, newObj metav1.Object) + type FakeRuntimeCache struct + Error error + InformersByGVK map[schema.GroupVersionKind]toolscache.SharedIndexInformer + Store *Store + Synced *bool + func NewFakeRuntimeCache(s *runtime.Scheme) *FakeRuntimeCache + func (c *FakeRuntimeCache) Add(obj any) error + func (c *FakeRuntimeCache) Delete(obj any) error + func (c *FakeRuntimeCache) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error + func (c *FakeRuntimeCache) GetInformer(ctx context.Context, obj client.Object, opts ...cache.InformerGetOption) (cache.Informer, error) + func (c *FakeRuntimeCache) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, ...) (cache.Informer, error) + func (c *FakeRuntimeCache) IndexField(ctx context.Context, obj client.Object, field string, ...) error + func (c *FakeRuntimeCache) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error + func (c *FakeRuntimeCache) RemoveInformer(ctx context.Context, obj client.Object) error + func (c *FakeRuntimeCache) Start(ctx context.Context) error + func (c *FakeRuntimeCache) Update(oldObj, newObj any) error + func (c *FakeRuntimeCache) WaitForCacheSync(ctx context.Context) bool + type Lister interface + List func() []object.Object + type Options struct + Logger logr.Logger + type Store struct + Store toolscache.Store + func NewStore() *Store + func (s *Store) Add(obj object.Object) error + func (s *Store) Delete(obj object.Object) error + func (s *Store) Get(obj object.Object) (object.Object, bool, error) + func (s *Store) GetByKey(key string) (object.Object, bool, error) + func (s *Store) List() []object.Object + func (s *Store) ListKeys() []string + func (s *Store) Replace(objs []object.Object, arg string) error + func (s *Store) Resync() error + func (s *Store) Update(obj object.Object) error + type ViewCache struct + func NewViewCache(opts CacheOptions) *ViewCache + func (c *ViewCache) Add(obj object.Object) error + func (c *ViewCache) Delete(obj object.Object) error + func (c *ViewCache) Dump(ctx context.Context, gvk schema.GroupVersionKind) []string + func (c *ViewCache) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error + func (c *ViewCache) GetCacheForKind(gvk schema.GroupVersionKind) (toolscache.Indexer, error) + func (c *ViewCache) GetInformer(ctx context.Context, obj client.Object, opts ...cache.InformerGetOption) (cache.Informer, error) + func (c *ViewCache) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, _ ...cache.InformerGetOption) (cache.Informer, error) + func (c *ViewCache) IndexField(ctx context.Context, obj client.Object, field string, ...) error + func (c *ViewCache) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error + func (c *ViewCache) RegisterCacheForKind(gvk schema.GroupVersionKind) error + func (c *ViewCache) RegisterInformerForKind(gvk schema.GroupVersionKind) error + func (c *ViewCache) RemoveInformer(ctx context.Context, obj client.Object) error + func (c *ViewCache) Start(ctx context.Context) error + func (c *ViewCache) Update(oldObj, newObj object.Object) error + func (c *ViewCache) WaitForCacheSync(_ context.Context) bool + func (c *ViewCache) Watch(ctx context.Context, list client.ObjectList, opts ...client.ListOption) (watch.Interface, error) + func (vc *ViewCache) GetClient() client.WithWatch + type ViewCacheInformer struct + func NewViewCacheInformer(gvk schema.GroupVersionKind, indexer toolscache.Indexer, logger logr.Logger) *ViewCacheInformer + func (c *ViewCacheInformer) AddEventHandler(handler toolscache.ResourceEventHandler) (toolscache.ResourceEventHandlerRegistration, error) + func (c *ViewCacheInformer) AddEventHandlerWithOptions(handler toolscache.ResourceEventHandler, _ toolscache.HandlerOptions) (toolscache.ResourceEventHandlerRegistration, error) + func (c *ViewCacheInformer) AddEventHandlerWithResyncPeriod(handler toolscache.ResourceEventHandler, resyncPeriod time.Duration) (toolscache.ResourceEventHandlerRegistration, error) + func (c *ViewCacheInformer) AddIndexers(indexers toolscache.Indexers) error + func (c *ViewCacheInformer) GetController() toolscache.Controller + func (c *ViewCacheInformer) GetIndexer() toolscache.Indexer + func (c *ViewCacheInformer) GetStore() toolscache.Store + func (c *ViewCacheInformer) HasSynced() bool + func (c *ViewCacheInformer) IsStopped() bool + func (c *ViewCacheInformer) LastSyncResourceVersion() string + func (c *ViewCacheInformer) RemoveEventHandler(registration toolscache.ResourceEventHandlerRegistration) error + func (c *ViewCacheInformer) Run(stopCh <-chan struct{}) + func (c *ViewCacheInformer) RunWithContext(ctx context.Context) + func (c *ViewCacheInformer) SetTransform(transform toolscache.TransformFunc) error + func (c *ViewCacheInformer) SetWatchErrorHandler(_ toolscache.WatchErrorHandler) error + func (c *ViewCacheInformer) SetWatchErrorHandlerWithContext(_ toolscache.WatchErrorHandlerWithContext) error + func (c *ViewCacheInformer) TriggerEvent(eventType toolscache.DeltaType, oldObj, newObj object.Object, ...) + type ViewCacheWatcher struct + func (w *ViewCacheWatcher) ResultChan() <-chan watch.Event + func (w *ViewCacheWatcher) Stop() + type ViewDiscovery struct + func NewViewDiscovery() *ViewDiscovery + func (d *ViewDiscovery) GetRegisteredViewGVKs() []schema.GroupVersionKind + func (d *ViewDiscovery) IsViewGroup(group string) bool + func (d *ViewDiscovery) IsViewKind(gvk schema.GroupVersionKind) bool + func (d *ViewDiscovery) IsViewListKind(gvk schema.GroupVersionKind) bool + func (d *ViewDiscovery) KindFromResource(resource string) (string, error) + func (d *ViewDiscovery) ListGVKFromObjectGVK(objGVK schema.GroupVersionKind) schema.GroupVersionKind + func (d *ViewDiscovery) ObjectGVKFromListGVK(listGVK schema.GroupVersionKind) schema.GroupVersionKind + func (d *ViewDiscovery) RegisterViewGVK(gvk schema.GroupVersionKind) error + func (d *ViewDiscovery) ResourceFromKind(kind string) string + func (d *ViewDiscovery) ServerGroups() (*metav1.APIGroupList, error) + func (d *ViewDiscovery) ServerGroupsAndResources() ([]*metav1.APIGroup, []*metav1.APIResourceList, error) + func (d *ViewDiscovery) ServerPreferredNamespacedResources() ([]*metav1.APIResourceList, error) + func (d *ViewDiscovery) ServerPreferredResources() ([]*metav1.APIResourceList, error) + func (d *ViewDiscovery) ServerResourcesForGroupVersion(groupVersion string) (*metav1.APIResourceList, error) + func (d *ViewDiscovery) UnregisterViewGVK(gvk schema.GroupVersionKind) error + type ViewDiscoveryInterface interface + GetRegisteredViewGVKs func() []schema.GroupVersionKind + IsViewGroup func(group string) bool + IsViewKind func(gvk schema.GroupVersionKind) bool + IsViewListKind func(gvk schema.GroupVersionKind) bool + KindFromResource func(resource string) (string, error) + ListGVKFromObjectGVK func(objGVK schema.GroupVersionKind) schema.GroupVersionKind + ObjectGVKFromListGVK func(listGVK schema.GroupVersionKind) schema.GroupVersionKind + RegisterViewGVK func(gvk schema.GroupVersionKind) error + ResourceFromKind func(kind string) string + UnregisterViewGVK func(gvk schema.GroupVersionKind) error + type ViewRESTMapper struct + func NewViewRESTMapper() *ViewRESTMapper + func (m *ViewRESTMapper) KindFor(resource schema.GroupVersionResource) (schema.GroupVersionKind, error) + func (m *ViewRESTMapper) KindsFor(resource schema.GroupVersionResource) ([]schema.GroupVersionKind, error) + func (m *ViewRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error) + func (m *ViewRESTMapper) RESTMappings(gk schema.GroupKind, versions ...string) ([]*meta.RESTMapping, error) + func (m *ViewRESTMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error) + func (m *ViewRESTMapper) ResourceSingularizer(resource string) (string, error) + func (m *ViewRESTMapper) ResourcesFor(input schema.GroupVersionResource) ([]schema.GroupVersionResource, error)
Go to main page