Namespace support to work without cluster scope, fixes #42

config.example.yaml

@@ -1,5 +1,6 @@
 logLevel: debug
 logFormat: json
+# namespace: my-namespace-only # Omitting it defaults to all namespaces.
 route:
   # Main route
   routes:

config.yaml

@@ -1,10 +1,11 @@
 logLevel: error
 logFormat: json
+# namespace: tekton-pipelines
 route:
   routes:
     - match:
         - receiver: "dump"
 receivers:
   - name: "dump"
     file:
-      path: "/tmp/deneme1"
+      path: "/dev/stdout"

main.go

@@ -63,7 +63,7 @@ func main() {
 	}
 
 	engine := exporter.NewEngine(&cfg, &exporter.ChannelBasedReceiverRegistry{})
-	w := kube.NewEventWatcher(kubeconfig, engine.OnEvent)
+	w := kube.NewEventWatcher(kubeconfig, cfg.Namespace, engine.OnEvent)
 
 	ctx, cancel := context.WithCancel(context.Background())
 	leaderLost := make(chan bool)

pkg/exporter/config.go

@@ -12,6 +12,7 @@ type Config struct {
 	// TODO: I am not sure what to do here.
 	LogLevel       string                    `yaml:"logLevel"`
 	LogFormat      string                    `yaml:"logFormat"`
+	Namespace      string                    `yaml:"namespace"`
 	LeaderElection kube.LeaderElectionConfig `yaml:"leaderElection"`
 	Route          Route                     `yaml:"route"`
 	Receivers      []sinks.ReceiverConfig    `yaml:"receivers"`

pkg/kube/watcher.go

@@ -20,9 +20,9 @@ type EventWatcher struct {
 	fn              EventHandler
 }
 
-func NewEventWatcher(config *rest.Config, fn EventHandler) *EventWatcher {
+func NewEventWatcher(config *rest.Config, namespace string, fn EventHandler) *EventWatcher {
 	clientset := kubernetes.NewForConfigOrDie(config)
-	factory := informers.NewSharedInformerFactory(clientset, 0)
+	factory := informers.NewSharedInformerFactoryWithOptions(clientset, 0, informers.WithNamespace(namespace))
 	informer := factory.Core().V1().Events().Informer()
 
 	watcher := &EventWatcher{