Documentation
¶
Index ¶
- func GetTerminationExitCode(k8sObjectsCache K8sObjectCache, ...) int32
- func ListContainersIDs(pod *corev1.Pod) []string
- func ListTerminatedContainers(pod *corev1.Pod) []string
- func MetaUniqueName(obj metav1.Object) string
- func UniqueName(namespace, name string) string
- type ApplicationProfileCache
- type ApplicationProfileCacheMock
- func (ap *ApplicationProfileCacheMock) AddHandler(_ context.Context, _ runtime.Object)
- func (ap *ApplicationProfileCacheMock) DeleteHandler(_ context.Context, _ runtime.Object)
- func (ap *ApplicationProfileCacheMock) GetApplicationProfile(_ string) *v1beta1.ApplicationProfile
- func (ap *ApplicationProfileCacheMock) GetCallStackSearchTree(_ string) *callstackcache.CallStackSearchTree
- func (ap *ApplicationProfileCacheMock) ModifyHandler(_ context.Context, _ runtime.Object)
- func (ap *ApplicationProfileCacheMock) WatchResources() []watcher.WatchResource
- type DnsCache
- type DnsCacheMock
- type K8sObjectCache
- type K8sObjectCacheMock
- func (k *K8sObjectCacheMock) DeleteSharedContainerData(containerID string)
- func (k *K8sObjectCacheMock) GetApiServerIpAddress() string
- func (k *K8sObjectCacheMock) GetPod(_, _ string) *corev1.Pod
- func (k *K8sObjectCacheMock) GetPodSpec(_, _ string) *corev1.PodSpec
- func (k *K8sObjectCacheMock) GetPodStatus(_, _ string) *corev1.PodStatus
- func (k *K8sObjectCacheMock) GetPods() []*corev1.Pod
- func (k *K8sObjectCacheMock) GetSharedContainerData(containerID string) *utils.WatchedContainerData
- func (k *K8sObjectCacheMock) SetSharedContainerData(containerID string, data *utils.WatchedContainerData)
- type NetworkNeighborhoodCache
- type NetworkNeighborhoodCacheMock
- func (ap *NetworkNeighborhoodCacheMock) AddHandler(_ context.Context, _ runtime.Object)
- func (ap *NetworkNeighborhoodCacheMock) DeleteHandler(_ context.Context, _ runtime.Object)
- func (ap *NetworkNeighborhoodCacheMock) GetNetworkNeighborhood(_ string) *v1beta1.NetworkNeighborhood
- func (ap *NetworkNeighborhoodCacheMock) ModifyHandler(_ context.Context, _ runtime.Object)
- func (ap *NetworkNeighborhoodCacheMock) WatchResources() []watcher.WatchResource
- type ObjectCache
- type ObjectCacheMock
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
list containerIDs from pod status
func ListTerminatedContainers ¶
list terminated containers from pod status
func MetaUniqueName ¶
func UniqueName ¶
Types ¶
type ApplicationProfileCache ¶
type ApplicationProfileCache interface {
GetApplicationProfile(containerID string) *v1beta1.ApplicationProfile
GetCallStackSearchTree(containerID string) *callstackcache.CallStackSearchTree
WatchResources() []watcher.WatchResource
AddHandler(ctx context.Context, obj runtime.Object)
ModifyHandler(ctx context.Context, obj runtime.Object)
DeleteHandler(ctx context.Context, obj runtime.Object)
}
type ApplicationProfileCacheMock ¶
type ApplicationProfileCacheMock struct {
}
func (*ApplicationProfileCacheMock) AddHandler ¶
func (ap *ApplicationProfileCacheMock) AddHandler(_ context.Context, _ runtime.Object)
func (*ApplicationProfileCacheMock) DeleteHandler ¶
func (ap *ApplicationProfileCacheMock) DeleteHandler(_ context.Context, _ runtime.Object)
func (*ApplicationProfileCacheMock) GetApplicationProfile ¶
func (ap *ApplicationProfileCacheMock) GetApplicationProfile(_ string) *v1beta1.ApplicationProfile
func (*ApplicationProfileCacheMock) GetCallStackSearchTree ¶
func (ap *ApplicationProfileCacheMock) GetCallStackSearchTree(_ string) *callstackcache.CallStackSearchTree
func (*ApplicationProfileCacheMock) ModifyHandler ¶
func (ap *ApplicationProfileCacheMock) ModifyHandler(_ context.Context, _ runtime.Object)
func (*ApplicationProfileCacheMock) WatchResources ¶
func (ap *ApplicationProfileCacheMock) WatchResources() []watcher.WatchResource
type DnsCacheMock ¶
type DnsCacheMock struct {
}
func (*DnsCacheMock) ResolveIpToDomain ¶
func (dc *DnsCacheMock) ResolveIpToDomain(_ string) string
type K8sObjectCache ¶
type K8sObjectCacheMock ¶
type K8sObjectCacheMock struct {
ApiServerIpAddress string
PodSpec corev1.PodSpec
PodStatus corev1.PodStatus
// contains filtered or unexported fields
}
func (*K8sObjectCacheMock) DeleteSharedContainerData ¶
func (k *K8sObjectCacheMock) DeleteSharedContainerData(containerID string)
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
func (*K8sObjectCacheMock) GetSharedContainerData ¶
func (k *K8sObjectCacheMock) GetSharedContainerData(containerID string) *utils.WatchedContainerData
func (*K8sObjectCacheMock) SetSharedContainerData ¶
func (k *K8sObjectCacheMock) SetSharedContainerData(containerID string, data *utils.WatchedContainerData)
type NetworkNeighborhoodCache ¶
type NetworkNeighborhoodCache interface {
GetNetworkNeighborhood(containerID string) *v1beta1.NetworkNeighborhood
WatchResources() []watcher.WatchResource
AddHandler(ctx context.Context, obj runtime.Object)
ModifyHandler(ctx context.Context, obj runtime.Object)
DeleteHandler(ctx context.Context, obj runtime.Object)
}
type NetworkNeighborhoodCacheMock ¶
type NetworkNeighborhoodCacheMock struct {
}
func (*NetworkNeighborhoodCacheMock) AddHandler ¶
func (ap *NetworkNeighborhoodCacheMock) AddHandler(_ context.Context, _ runtime.Object)
func (*NetworkNeighborhoodCacheMock) DeleteHandler ¶
func (ap *NetworkNeighborhoodCacheMock) DeleteHandler(_ context.Context, _ runtime.Object)
func (*NetworkNeighborhoodCacheMock) GetNetworkNeighborhood ¶
func (ap *NetworkNeighborhoodCacheMock) GetNetworkNeighborhood(_ string) *v1beta1.NetworkNeighborhood
func (*NetworkNeighborhoodCacheMock) ModifyHandler ¶
func (ap *NetworkNeighborhoodCacheMock) ModifyHandler(_ context.Context, _ runtime.Object)
func (*NetworkNeighborhoodCacheMock) WatchResources ¶
func (ap *NetworkNeighborhoodCacheMock) WatchResources() []watcher.WatchResource
type ObjectCache ¶
type ObjectCache interface {
K8sObjectCache() K8sObjectCache
ApplicationProfileCache() ApplicationProfileCache
NetworkNeighborhoodCache() NetworkNeighborhoodCache
DnsCache() DnsCache
}
type ObjectCacheMock ¶
type ObjectCacheMock struct {
}
func NewObjectCacheMock ¶
func NewObjectCacheMock() *ObjectCacheMock
func (*ObjectCacheMock) ApplicationProfileCache ¶
func (om *ObjectCacheMock) ApplicationProfileCache() ApplicationProfileCache
func (*ObjectCacheMock) DnsCache ¶
func (om *ObjectCacheMock) DnsCache() DnsCache
func (*ObjectCacheMock) K8sObjectCache ¶
func (om *ObjectCacheMock) K8sObjectCache() K8sObjectCache
func (*ObjectCacheMock) NetworkNeighborhoodCache ¶
func (om *ObjectCacheMock) NetworkNeighborhoodCache() NetworkNeighborhoodCache
Source Files
¶
Click to show internal directories.
Click to hide internal directories.