Versions in this module Expand all Collapse all v0 v0.2.2 Aug 17, 2020 v0.2.1 Aug 17, 2020 Changes in this version + const ClusterRetryTimeout + func NewClusterCache(config *rest.Config, opts ...UpdateSettingsFunc) *clusterCache + type ClusterCache interface + EnsureSynced func() error + GetAPIGroups func() []metav1.APIGroup + GetClusterInfo func() ClusterInfo + GetManagedLiveObjs func(targetObjs []*unstructured.Unstructured, isManaged func(r *Resource) bool) (map[kube.ResourceKey]*unstructured.Unstructured, error) + GetNamespaceTopLevelResources func(namespace string) map[kube.ResourceKey]*Resource + GetServerVersion func() string + Invalidate func(opts ...UpdateSettingsFunc) + IsNamespaced func(gk schema.GroupKind) (bool, error) + IterateHierarchy func(key kube.ResourceKey, ...) + OnEvent func(handler OnEventHandler) Unsubscribe + OnResourceUpdated func(handler OnResourceUpdatedHandler) Unsubscribe + type ClusterInfo struct + APIsCount int + K8SVersion string + LastCacheSyncTime *time.Time + ResourcesCount int + Server string + SyncError error + 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 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 SetNamespaces(namespaces []string) UpdateSettingsFunc + func SetPopulateResourceInfoHandler(handler OnPopulateResourceInfoHandler) UpdateSettingsFunc + func SetResyncTimeout(timeout time.Duration) UpdateSettingsFunc + func SetSettings(settings Settings) 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