objectcache

Documentation

Index

• func GetTerminationExitCode(k8sObjectsCache K8sObjectCache, ...) int32
• func ListContainersIDs(pod *corev1.Pod) []string
• func ListTerminatedContainers(pod *corev1.Pod) []string
• func UniqueName(namespace, name string) string
• func UnstructuredToPod(obj *unstructured.Unstructured) (*corev1.Pod, error)
• func UnstructuredUniqueName(obj *unstructured.Unstructured) string
• type ApplicationActivityCache
• type ApplicationActivityCacheMock
  • func (ap *ApplicationActivityCacheMock) GetApplicationActivity(_, _ string) *v1beta1.ApplicationActivity
• type ApplicationProfileCache
• type ApplicationProfileCacheMock
  • func (ap *ApplicationProfileCacheMock) GetApplicationProfile(_ string) *v1beta1.ApplicationProfile
• type K8sObjectCache
• type K8sObjectCacheMock
  • func (k *K8sObjectCacheMock) GetApiServerIpAddress() string
  • func (k *K8sObjectCacheMock) GetPodSpec(_, _ string) *corev1.PodSpec
  • func (k *K8sObjectCacheMock) GetPodStatus(_, _ string) *corev1.PodStatus
  • func (k *K8sObjectCacheMock) GetPods() []*corev1.Pod
• type NetworkNeighborhoodCache
• type NetworkNeighborhoodCacheMock
  • func (ap *NetworkNeighborhoodCacheMock) GetNetworkNeighborhood(_ string) *v1beta1.NetworkNeighborhood
• type ObjectCache
• type ObjectCacheMock
  • func NewObjectCacheMock() *ObjectCacheMock
  • func (om *ObjectCacheMock) ApplicationProfileCache() ApplicationProfileCache
  • func (om *ObjectCacheMock) K8sObjectCache() K8sObjectCache
  • func (om *ObjectCacheMock) NetworkNeighborhoodCache() NetworkNeighborhoodCache

Functions

func GetTerminationExitCode

func GetTerminationExitCode(k8sObjectsCache K8sObjectCache, namespace, podName, containerName, containerID string) int32

GetTerminationExitCode returns the termination exit code of the container, otherwise -1

func ListContainersIDs

func ListContainersIDs(pod *corev1.Pod) []string

list containerIDs from pod status

func ListTerminatedContainers

func ListTerminatedContainers(pod *corev1.Pod) []string

list terminated containers from pod status

func UniqueName

func UniqueName(namespace, name string) string

func UnstructuredToPod

func UnstructuredToPod(obj *unstructured.Unstructured) (*corev1.Pod, error)

func UnstructuredUniqueName

func UnstructuredUniqueName(obj *unstructured.Unstructured) string

Types

type ApplicationActivityCache

type ApplicationActivityCache interface {
	GetApplicationActivity(namespace, name string) *v1beta1.ApplicationActivity
}

type ApplicationActivityCacheMock

type ApplicationActivityCacheMock struct {
}

func (*ApplicationActivityCacheMock) GetApplicationActivity

func (ap *ApplicationActivityCacheMock) GetApplicationActivity(_, _ string) *v1beta1.ApplicationActivity

type ApplicationProfileCache

type ApplicationProfileCache interface {
	GetApplicationProfile(containerID string) *v1beta1.ApplicationProfile
}

type ApplicationProfileCacheMock

type ApplicationProfileCacheMock struct {
}

func (*ApplicationProfileCacheMock) GetApplicationProfile

func (ap *ApplicationProfileCacheMock) GetApplicationProfile(_ string) *v1beta1.ApplicationProfile

type K8sObjectCache

type K8sObjectCache interface {
	GetPodSpec(namespace, podName string) *corev1.PodSpec
	GetPodStatus(namespace, podName string) *corev1.PodStatus
	GetApiServerIpAddress() string
	GetPods() []*corev1.Pod
}

type K8sObjectCacheMock

type K8sObjectCacheMock struct {
	ApiServerIpAddress string
	PodSpec            corev1.PodSpec
	PodStatus          corev1.PodStatus
}

func (*K8sObjectCacheMock) GetApiServerIpAddress

func (k *K8sObjectCacheMock) GetApiServerIpAddress() string

func (*K8sObjectCacheMock) GetPodSpec

func (k *K8sObjectCacheMock) GetPodSpec(_, _ string) *corev1.PodSpec

func (*K8sObjectCacheMock) GetPodStatus

func (k *K8sObjectCacheMock) GetPodStatus(_, _ string) *corev1.PodStatus

func (*K8sObjectCacheMock) GetPods

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

type NetworkNeighborhoodCache

type NetworkNeighborhoodCache interface {
	GetNetworkNeighborhood(containerID string) *v1beta1.NetworkNeighborhood
}

type NetworkNeighborhoodCacheMock

type NetworkNeighborhoodCacheMock struct {
}

func (*NetworkNeighborhoodCacheMock) GetNetworkNeighborhood

func (ap *NetworkNeighborhoodCacheMock) GetNetworkNeighborhood(_ string) *v1beta1.NetworkNeighborhood

type ObjectCache

type ObjectCache interface {
	K8sObjectCache() K8sObjectCache
	ApplicationProfileCache() ApplicationProfileCache
	NetworkNeighborhoodCache() NetworkNeighborhoodCache
}

type ObjectCacheMock

type ObjectCacheMock struct {
}

func NewObjectCacheMock

func NewObjectCacheMock() *ObjectCacheMock

func (*ObjectCacheMock) ApplicationProfileCache

func (om *ObjectCacheMock) ApplicationProfileCache() ApplicationProfileCache

func (*ObjectCacheMock) K8sObjectCache

func (om *ObjectCacheMock) K8sObjectCache() K8sObjectCache

func (*ObjectCacheMock) NetworkNeighborhoodCache

func (om *ObjectCacheMock) NetworkNeighborhoodCache() NetworkNeighborhoodCache