cache

Documentation

Index

• type IstioCache
• type KialiCache
  • func NewKialiCache() (KialiCache, error)
• type KubernetesCache
• type NamespacesCache
• type ProxyStatusCache

Types

type IstioCache

type IstioCache interface {
	CheckIstioResource(resourceType string) bool
	GetIstioObjects(namespace string, resourceType string, labelSelector string) ([]kubernetes.IstioObject, error)
}

type KialiCache

type KialiCache interface {
	// Control methods
	// Check if a namespace is listed to be cached; if yes, creates a cache for that namespace
	CheckNamespace(namespace string) bool

	// Clear a namespace's cache
	RefreshNamespace(namespace string)
	// Stop all caches
	Stop()

	KubernetesCache
	IstioCache
	NamespacesCache
	ProxyStatusCache
}

func NewKialiCache

func NewKialiCache() (KialiCache, error)

type KubernetesCache

type KubernetesCache interface {
	GetConfigMap(namespace, name string) (*core_v1.ConfigMap, error)
	GetDeployments(namespace string) ([]apps_v1.Deployment, error)
	GetDeployment(namespace, name string) (*apps_v1.Deployment, error)
	GetStatefulSets(namespace string) ([]apps_v1.StatefulSet, error)
	GetStatefulSet(namespace, name string) (*apps_v1.StatefulSet, error)
	GetServices(namespace string, selectorLabels map[string]string) ([]core_v1.Service, error)
	GetPods(namespace, labelSelector string) ([]core_v1.Pod, error)
	GetReplicaSets(namespace string) ([]apps_v1.ReplicaSet, error)
}

type NamespacesCache

type NamespacesCache interface {
	SetNamespaces(token string, namespaces []models.Namespace)
	GetNamespaces(token string) []models.Namespace
	GetNamespace(token string, namespace string) *models.Namespace
	RefreshTokenNamespaces()
}

type ProxyStatusCache

type ProxyStatusCache interface {
	CheckProxyStatus() bool
	GetPodProxyStatus(namespace, pod string) *kubernetes.ProxyStatus
	SetProxyStatus(proxyStatus []*kubernetes.ProxyStatus)
	RefreshProxyStatus()
}