Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeK8sWatcher ¶
type FakeK8sWatcher struct {
// contains filtered or unexported fields
}
FakeK8sWatcher is used as an "empty" K8sResourceWatcher when --enable-k8s-api flag is not set.
func NewFakeK8sWatcher ¶
func NewFakeK8sWatcher(pods []interface{}) *FakeK8sWatcher
NewK8sWatcher returns a pointer to an initialized FakeK8sWatcher struct.
func (*FakeK8sWatcher) FindPod ¶
func (watcher *FakeK8sWatcher) FindPod(containerID string) (*corev1.Pod, *corev1.ContainerStatus, bool)
FindPod implements K8sResourceWatcher.FindPod.
type K8sResourceWatcher ¶
type K8sResourceWatcher interface {
// Find a pod/container pair for the given container ID.
FindPod(containerID string) (*corev1.Pod, *corev1.ContainerStatus, bool)
// Get PodInfo and Endpoint ID for a containerId.
GetPodInfo(containerID, binary, args string, nspid uint32) (*tetragon.Pod, *hubblev1.Endpoint)
}
K8sResourceWatcher defines an interface for accessing various resources from Kubernetes API.
type K8sWatcher ¶
type K8sWatcher struct {
// contains filtered or unexported fields
}
K8sWatcher maintains a local cache of k8s resources.
func NewK8sWatcher ¶
func NewK8sWatcher(k8sClient *kubernetes.Clientset, stateSyncIntervalSec time.Duration) *K8sWatcher
NewK8sWatcher returns a pointer to an initialized K8sWatcher struct.
func (*K8sWatcher) FindPod ¶
func (watcher *K8sWatcher) FindPod(containerID string) (*corev1.Pod, *corev1.ContainerStatus, bool)
FindPod implements K8sResourceWatcher.FindPod.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.