Versions in this module Expand all Collapse all v0 v0.7.3 Jul 29, 2026 Changes in this version + const ClusterRetryTimeout + const RespectRbacDisabled + const RespectRbacNormal + const RespectRbacStrict + func ListRetryFuncAlways(_ error) bool + func ListRetryFuncNever(_ error) bool + func NewClusterCache(config *rest.Config, opts ...UpdateSettingsFunc) *clusterCache + func NewNoopSettings() *noopSettings + func ResourceOfGroupKind(group string, kind string) func(r *Resource) bool + func TopLevelResource(r *Resource) bool + type ClusterCache interface + EnsureSynced func() error + FindResources func(namespace string, predicates ...func(r *Resource) bool) map[kube.ResourceKey]*Resource + GetAPIResources func() []kube.APIResourceInfo + GetClusterInfo func() ClusterInfo + GetGVKParser func() *managedfields.GvkParser + GetManagedLiveObjs func(targetObjs []*unstructured.Unstructured, isManaged func(r *Resource) bool) (map[kube.ResourceKey]*unstructured.Unstructured, error) + GetOpenAPISchema func() openapi.Resources + GetServerVersion func() string + Invalidate func(opts ...UpdateSettingsFunc) + IsNamespaced func(gk schema.GroupKind) (bool, error) + IterateHierarchyV2 func(keys []kube.ResourceKey, ...) + OnEvent func(handler OnEventHandler) Unsubscribe + OnProcessEventsHandler func(handler OnProcessEventsHandler) Unsubscribe + OnResourceUpdated func(handler OnResourceUpdatedHandler) Unsubscribe + type ClusterInfo struct + APIResources []kube.APIResourceInfo + APIsCount int + K8SVersion string + LastCacheSyncTime *time.Time + ResourcesCount int + Server string + SyncError error + type ListRetryFunc func(err error) bool + type OnEventHandler func(event watch.EventType, un *unstructured.Unstructured) + type OnPopulateResourceInfoHandler func(un *unstructured.Unstructured, isRoot bool) (info any, cacheManifest bool) + type OnProcessEventsHandler func(duration time.Duration, processedEventsNumber int) + type OnResourceUpdatedHandler func(newRes *Resource, oldRes *Resource, ...) + type Resource struct + CreationTimestamp *metav1.Time + Info any + OwnerRefs []metav1.OwnerReference + Ref corev1.ObjectReference + Resource *unstructured.Unstructured + ResourceVersion string + func (r *Resource) ResourceKey() kube.ResourceKey + type Settings struct + ResourceHealthOverride health.HealthOverride + ResourcesFilter kube.ResourceFilter + type Unsubscribe func() + type UpdateSettingsFunc func(cache *clusterCache) + func SetBatchEventsProcessing(batchProcessing bool) UpdateSettingsFunc + func SetClusterResources(val bool) UpdateSettingsFunc + func SetClusterSyncRetryTimeout(timeout time.Duration) UpdateSettingsFunc + func SetConfig(config *rest.Config) UpdateSettingsFunc + func SetEventProcessingInterval(interval time.Duration) UpdateSettingsFunc + func SetKubectl(kubectl kube.Kubectl) UpdateSettingsFunc + func SetListPageBufferSize(listPageBufferSize int32) UpdateSettingsFunc + func SetListPageSize(listPageSize int64) UpdateSettingsFunc + func SetListSemaphore(listSemaphore WeightedSemaphore) UpdateSettingsFunc + func SetLogr(log logr.Logger) UpdateSettingsFunc + func SetNamespaces(namespaces []string) UpdateSettingsFunc + func SetPopulateResourceInfoHandler(handler OnPopulateResourceInfoHandler) UpdateSettingsFunc + func SetRespectRBAC(respectRBAC int) UpdateSettingsFunc + func SetResyncTimeout(timeout time.Duration) UpdateSettingsFunc + func SetRetryOptions(maxRetries int32, useBackoff bool, retryFunc ListRetryFunc) UpdateSettingsFunc + func SetSettings(settings Settings) UpdateSettingsFunc + func SetTracer(tracer tracing.Tracer) UpdateSettingsFunc + func SetWatchResyncTimeout(timeout time.Duration) UpdateSettingsFunc + type WeightedSemaphore interface + Acquire func(ctx context.Context, n int64) error + Release func(n int64) + TryAcquire func(n int64) bool
Go to main page