return evt filter description

Author: cmaster11

example/main.go

@@ -26,8 +26,8 @@ func main() {
 		log.Fatal(err)
 	}
 
-	if err := watcher.Start(func(event *v1.Event) {
-		log.Printf("got event: %+v\n", event)
+	if err := watcher.Start(func(event *v1.Event, filterDescription string) {
+		log.Printf("got event (%s): %+v\n", filterDescription, event)
 	}); err != nil {
 		log.Fatal(err)
 	}

internal/config.go

@@ -28,14 +28,14 @@ func (c *Config) Validate() error {
 	return nil
 }
 
-func (c *Config) MatchesEvent(event *v1.Event) bool {
+func (c *Config) MatchingEventFilter(event *v1.Event) *EventFilter {
 	for _, filter := range c.Filters {
 		if filter.Matches(event) {
-			return true
+			return filter
 		}
 	}
 
-	return false
+	return nil
 }
 
 func (c *Config) Dump() string {

internal/filter.go

@@ -2,7 +2,9 @@ package internal
 
 import (
 	"errors"
+	"fmt"
 	v1 "k8s.io/api/core/v1"
+	"strings"
 )
 
 type EventFilter struct {
@@ -62,3 +64,24 @@ func (f *EventFilter) Matches(event *v1.Event) bool {
 
 	return true
 }
+
+func (f *EventFilter) String() string {
+	var elements []string
+	if f.ObjectNamespace != nil {
+		elements = append(elements, fmt.Sprintf("objectNamespace=%s", f.ObjectNamespace.String()))
+	}
+	if f.ObjectKind != nil {
+		elements = append(elements, fmt.Sprintf("objectKind=%s", f.ObjectKind.String()))
+	}
+	if f.ObjectName != nil {
+		elements = append(elements, fmt.Sprintf("objectName=%s", f.ObjectName.String()))
+	}
+	if f.EventType != nil {
+		elements = append(elements, fmt.Sprintf("eventType=%s", f.EventType.String()))
+	}
+	if f.EventReason != nil {
+		elements = append(elements, fmt.Sprintf("eventReason=%s", f.EventReason.String()))
+	}
+
+	return strings.Join(elements, ",")
+}

main.go

@@ -27,7 +27,7 @@ type K8sEventWatcher struct {
 
 	chStop   chan struct{}
 	lock     sync.Mutex
-	callback func(event *v1.Event)
+	callback func(event *v1.Event, filterDescription string)
 
 	Debug bool
 }
@@ -108,17 +108,16 @@ func (w *K8sEventWatcher) onAddEvent(obj interface{}) {
 		return
 	}
 
-	if !w.config.MatchesEvent(evt) {
-		w.logEntryDebug("discarded event: %+v", evt)
+	if filter := w.config.MatchingEventFilter(evt); filter != nil {
+		w.logEntryDebug("matched event: %+v", evt)
+		w.callback(evt, filter.String())
 		return
 	}
 
-	w.logEntryDebug("matched event: %+v", evt)
-
-	w.callback(evt)
+	w.logEntryDebug("discarded event: %+v", evt)
 }
 
-func (w *K8sEventWatcher) Start(callback func(event *v1.Event)) error {
+func (w *K8sEventWatcher) Start(callback func(event *v1.Event, filterDescription string)) error {
 	if callback == nil {
 		return errorf("callback cannot be null")
 	}