cache

type ClusterCache interface {
	EnsureSynced() error
	GetServerVersion() string
	GetAPIGroups() []metav1.APIGroup
	Invalidate(settingsCallback func(*rest.Config, []string, Settings) (*rest.Config, []string, Settings))
	GetNamespaceTopLevelResources(namespace string) map[kube.ResourceKey]*Resource
	IterateHierarchy(key kube.ResourceKey, action func(resource *Resource, namespaceResources map[kube.ResourceKey]*Resource))
	IsNamespaced(gk schema.GroupKind) (bool, error)
	GetManagedLiveObjs(targetObjs []*unstructured.Unstructured, isManaged func(r *Resource) bool) (map[kube.ResourceKey]*unstructured.Unstructured, error)
	GetClusterInfo() ClusterInfo
	SetPopulateResourceInfoHandler(handler OnPopulateResourceInfoHandler)
	OnResourceUpdated(handler OnResourceUpdatedHandler) Unsubscribe
	OnEvent(handler OnEventHandler) Unsubscribe
}

type ClusterInfo struct {
	Server            string
	K8SVersion        string
	ResourcesCount    int
	APIsCount         int
	LastCacheSyncTime *time.Time
}

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, namespaceResources map[kube.ResourceKey]*Resource)

type Resource struct {
	ResourceVersion string
	Ref             v1.ObjectReference
	OwnerRefs       []metav1.OwnerReference
	Info            interface{}

	// available only for root application nodes
	Resource *unstructured.Unstructured
}

type Settings struct {
	ResourceHealthOverride health.HealthOverride
	ResourcesFilter        kube.ResourceFilter
}

type Unsubscribe func()