Versions in this module Expand all Collapse all v0 v0.7.5 Nov 26, 2024 v0.7.4 Nov 26, 2024 Changes in this version + const ClusterRetryTimeout + const RespectRbacDisabled + const RespectRbacNormal + const RespectRbacStrict + func ListRetryFuncAlways(err error) bool + func ListRetryFuncNever(err 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) + IterateHierarchy func(key kube.ResourceKey, ...) + IterateHierarchyV2 func(keys []kube.ResourceKey, ...) + OnEvent func(handler OnEventHandler) 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 interface{}, cacheManifest bool) + type OnResourceUpdatedHandler func(newRes *Resource, oldRes *Resource, ...) + type Resource struct + CreationTimestamp *metav1.Time + Info interface{} + OwnerRefs []metav1.OwnerReference + Ref v1.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 SetClusterResources(val bool) UpdateSettingsFunc + func SetClusterSyncRetryTimeout(timeout time.Duration) UpdateSettingsFunc + func SetConfig(config *rest.Config) 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