k8scache

Documentation

Index

• type K8sObjectCacheImpl
  • func NewK8sObjectCache(nodeName string, k8sClient k8sclient.K8sClientInterface, ...) (*K8sObjectCacheImpl, error)
  • func (k *K8sObjectCacheImpl) AddHandler(_ context.Context, obj runtime.Object)
  • func (k *K8sObjectCacheImpl) DeleteHandler(_ context.Context, obj runtime.Object)
  • func (k *K8sObjectCacheImpl) GetApiServerIpAddress() string
  • func (k *K8sObjectCacheImpl) GetPodSpec(namespace, podName string) *corev1.PodSpec
  • func (k *K8sObjectCacheImpl) GetPodStatus(namespace, podName string) *corev1.PodStatus
  • func (k *K8sObjectCacheImpl) GetPods() []*corev1.Pod
  • func (k *K8sObjectCacheImpl) IsPreRunningContainer(containerID string) bool
  • func (k *K8sObjectCacheImpl) ModifyHandler(_ context.Context, obj runtime.Object)
  • func (k *K8sObjectCacheImpl) WatchResources() []watcher.WatchResource

Types

type K8sObjectCacheImpl

type K8sObjectCacheImpl struct {
	// contains filtered or unexported fields
}

func NewK8sObjectCache

func NewK8sObjectCache(nodeName string, k8sClient k8sclient.K8sClientInterface, preRunningContainersIDs mapset.Set[string]) (*K8sObjectCacheImpl, error)

func (*K8sObjectCacheImpl) AddHandler

func (k *K8sObjectCacheImpl) AddHandler(_ context.Context, obj runtime.Object)

func (*K8sObjectCacheImpl) DeleteHandler

func (k *K8sObjectCacheImpl) DeleteHandler(_ context.Context, obj runtime.Object)

func (*K8sObjectCacheImpl) GetApiServerIpAddress

func (k *K8sObjectCacheImpl) GetApiServerIpAddress() string

func (*K8sObjectCacheImpl) GetPodSpec

func (k *K8sObjectCacheImpl) GetPodSpec(namespace, podName string) *corev1.PodSpec

GetPodSpec returns the pod spec for the given namespace and pod name, if not found returns nil

func (*K8sObjectCacheImpl) GetPodStatus

func (k *K8sObjectCacheImpl) GetPodStatus(namespace, podName string) *corev1.PodStatus

GetPodStatus returns the pod status for the given namespace and pod name, if not found returns nil

func (*K8sObjectCacheImpl) GetPods

func (k *K8sObjectCacheImpl) GetPods() []*corev1.Pod

func (*K8sObjectCacheImpl) IsPreRunningContainer

func (k *K8sObjectCacheImpl) IsPreRunningContainer(containerID string) bool

IsPreRunningContainer returns true if the container was running before the agent started

func (*K8sObjectCacheImpl) ModifyHandler

func (k *K8sObjectCacheImpl) ModifyHandler(_ context.Context, obj runtime.Object)

func (*K8sObjectCacheImpl) WatchResources

func (k *K8sObjectCacheImpl) WatchResources() []watcher.WatchResource