cache

Documentation

Index

• type IstioCache
• type KialiCache
  • func FakeGatewaysKialiCache(gws []*networking_v1beta1.Gateway) KialiCache
  • func FakeServicesKialiCache(rss []*kubernetes.RegistryService, gws []*networking_v1beta1.Gateway, ...) KialiCache
  • func FakeTlsKialiCache(token string, namespaces []string, pa []*security_v1beta1.PeerAuthentication, ...) KialiCache
  • func NewKialiCache() (KialiCache, error)
• type KubernetesCache
• type NamespacesCache
• type ProxyStatusCache
• type RegistryRefreshHandler
  • func NewRegistryHandler(cache KialiCache, namespace string) RegistryRefreshHandler
  • func (sh RegistryRefreshHandler) OnAdd(obj interface{})
  • func (sh RegistryRefreshHandler) OnDelete(obj interface{})
  • func (sh RegistryRefreshHandler) OnUpdate(oldObj, newObj interface{})
• type RegistryStatusCache

Types

type IstioCache

type IstioCache interface {
	CheckIstioResource(resourceType string) bool

	GetDestinationRule(namespace, name string) (*networking_v1beta1.DestinationRule, error)
	GetDestinationRules(namespace, labelSelector string) ([]*networking_v1beta1.DestinationRule, error)
	GetEnvoyFilter(namespace, name string) (*networking_v1alpha3.EnvoyFilter, error)
	GetEnvoyFilters(namespace, labelSelector string) ([]*networking_v1alpha3.EnvoyFilter, error)
	GetGateway(namespace, name string) (*networking_v1beta1.Gateway, error)
	GetGateways(namespace, labelSelector string) ([]*networking_v1beta1.Gateway, error)
	GetServiceEntry(namespace, name string) (*networking_v1beta1.ServiceEntry, error)
	GetServiceEntries(namespace, labelSelector string) ([]*networking_v1beta1.ServiceEntry, error)
	GetSidecar(namespace, name string) (*networking_v1beta1.Sidecar, error)
	GetSidecars(namespace, labelSelector string) ([]*networking_v1beta1.Sidecar, error)
	GetVirtualService(namespace, name string) (*networking_v1beta1.VirtualService, error)
	GetVirtualServices(namespace, labelSelector string) ([]*networking_v1beta1.VirtualService, error)
	GetWorkloadEntry(namespace, name string) (*networking_v1beta1.WorkloadEntry, error)
	GetWorkloadEntries(namespace, labelSelector string) ([]*networking_v1beta1.WorkloadEntry, error)
	GetWorkloadGroup(namespace, name string) (*networking_v1beta1.WorkloadGroup, error)
	GetWorkloadGroups(namespace, labelSelector string) ([]*networking_v1beta1.WorkloadGroup, error)
	GetWasmPlugin(namespace, name string) (*extentions_v1alpha1.WasmPlugin, error)
	GetWasmPlugins(namespace, labelSelector string) ([]*extentions_v1alpha1.WasmPlugin, error)
	GetTelemetry(namespace, name string) (*v1alpha1.Telemetry, error)
	GetTelemetries(namespace, labelSelector string) ([]*v1alpha1.Telemetry, error)

	GetAuthorizationPolicy(namespace, name string) (*security_v1beta1.AuthorizationPolicy, error)
	GetAuthorizationPolicies(namespace, labelSelector string) ([]*security_v1beta1.AuthorizationPolicy, error)
	GetPeerAuthentication(namespace, name string) (*security_v1beta1.PeerAuthentication, error)
	GetPeerAuthentications(namespace, labelSelector string) ([]*security_v1beta1.PeerAuthentication, error)
	GetRequestAuthentication(namespace, name string) (*security_v1beta1.RequestAuthentication, error)
	GetRequestAuthentications(namespace, labelSelector string) ([]*security_v1beta1.RequestAuthentication, 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()

	// Kubernetes Client used for cache
	GetClient() *kubernetes.K8SClient

	KubernetesCache
	IstioCache
	NamespacesCache
	ProxyStatusCache
	RegistryStatusCache
}

func FakeGatewaysKialiCache

func FakeGatewaysKialiCache(gws []*networking_v1beta1.Gateway) KialiCache

Fake KialiCache used for Gateway Scenarios It populates the Namespaces, Informers and Gateway information needed

func FakeServicesKialiCache

func FakeServicesKialiCache(rss []*kubernetes.RegistryService,
	gws []*networking_v1beta1.Gateway,
	vss []*networking_v1beta1.VirtualService,
	drs []*networking_v1beta1.DestinationRule,
	ses []*networking_v1beta1.ServiceEntry,
	sds []*networking_v1beta1.Sidecar,
	ras []*security_v1beta1.RequestAuthentication,
	wes []*networking_v1beta1.WorkloadEntry) KialiCache

Fake KialiCache used for RegistryServices and All IstioConfigs Scenarios It populates the Namespaces, Informers and Registry information needed

func FakeTlsKialiCache

func FakeTlsKialiCache(token string, namespaces []string, pa []*security_v1beta1.PeerAuthentication, dr []*networking_v1beta1.DestinationRule) KialiCache

Fake KialiCache used for TLS Scenarios It populates the Namespaces, Informers and Registry information needed

func NewKialiCache

func NewKialiCache() (KialiCache, error)

type KubernetesCache

type KubernetesCache interface {
	GetConfigMap(namespace, name string) (*core_v1.ConfigMap, error)
	GetDaemonSets(namespace string) ([]apps_v1.DaemonSet, error)
	GetDaemonSet(namespace, name string) (*apps_v1.DaemonSet, error)
	GetDeployments(namespace string) ([]apps_v1.Deployment, error)
	GetDeployment(namespace, name string) (*apps_v1.Deployment, error)
	GetEndpoints(namespace, name string) (*core_v1.Endpoints, 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)
	GetService(namespace string, name 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()
}

type RegistryRefreshHandler

type RegistryRefreshHandler struct {
	Cache     KialiCache
	Namespace string
	cache.ResourceEventHandler
}

func NewRegistryHandler

func NewRegistryHandler(cache KialiCache, namespace string) RegistryRefreshHandler

func (RegistryRefreshHandler) OnAdd

func (sh RegistryRefreshHandler) OnAdd(obj interface{})

func (RegistryRefreshHandler) OnDelete

func (sh RegistryRefreshHandler) OnDelete(obj interface{})

func (RegistryRefreshHandler) OnUpdate

func (sh RegistryRefreshHandler) OnUpdate(oldObj, newObj interface{})

type RegistryStatusCache

type RegistryStatusCache interface {
	CheckRegistryStatus() bool
	GetRegistryStatus() *kubernetes.RegistryStatus
	SetRegistryStatus(registryStatus *kubernetes.RegistryStatus)
	RefreshRegistryStatus()
}