Improve Pod's watcher options

Signed-off-by: chrismark <chrismarkou92@gmail.com>
elastic · Jul 13, 2021 · 929c183 · 929c183
1 parent 4f12589
commit 929c183
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/x-pack/elastic-agent/pkg/composable/providers/kubernetes/config.go b/x-pack/elastic-agent/pkg/composable/providers/kubernetes/config.go
@@ -16,6 +16,7 @@ import (
 // Config for kubernetes provider
 type Config struct {
 	KubeConfig     string        `config:"kube_config"`
+	Namespace      string        `config:"namespace"`
 	SyncPeriod     time.Duration `config:"sync_period"`
 	CleanupTimeout time.Duration `config:"cleanup_timeout" validate:"positive"`
 

diff --git a/x-pack/elastic-agent/pkg/composable/providers/kubernetes/pod.go b/x-pack/elastic-agent/pkg/composable/providers/kubernetes/pod.go
@@ -34,9 +34,10 @@ type podData struct {
 // NewPodWatcher creates a watcher that can discover and process pod objects
 func NewPodWatcher(comm composable.DynamicProviderComm, cfg *Config, logger *logp.Logger, client k8s.Interface) (kubernetes.Watcher, error) {
 	watcher, err := kubernetes.NewWatcher(client, &kubernetes.Pod{}, kubernetes.WatchOptions{
-		SyncTimeout: cfg.SyncPeriod,
-		Node:        cfg.Node,
-		//Namespace:   p.config.Namespace,
+		SyncTimeout:  cfg.SyncPeriod,
+		Node:         cfg.Node,
+		Namespace:    cfg.Namespace,
+		HonorReSyncs: true,
 	}, nil)
 	if err != nil {
 		return nil, errors.New(err, "couldn't create kubernetes watcher")