process: Add a function to access K8sResourceWatcher

Add a function that returns K8sResourceWatcher. This makes it easier for users of the process package to associate process information with Kubernetes resources. Signed-off-by: Michi Mutsuzaki <[email protected]>
cilium · Aug 27, 2023 · 00eebba · 00eebba
1 parent 7f907d5
commit 00eebba
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/process/process.go b/pkg/process/process.go
@@ -355,3 +355,9 @@ func AddCloneEvent(event *tetragonAPI.MsgCloneEvent) error {
 func Get(execId string) (*ProcessInternal, error) {
 	return procCache.get(execId)
 }
+
+// GetK8s returns K8sResourceWatcher. You must call InitCache before calling this function to ensure
+// that k8s has been initialized.
+func GetK8s() watcher.K8sResourceWatcher {
+	return k8s
+}