core api event support

Author: Avi-Robusta

README.md

@@ -18,7 +18,7 @@
 # Latest image
 
 ```
-us-central1-docker.pkg.dev/genuine-flight-317411/devel/kubewatch:v2.4
+us-central1-docker.pkg.dev/genuine-flight-317411/devel/kubewatch:v2.5
 ```
 
 # Usage
@@ -92,6 +92,7 @@ resourcesToWatch:
   secret: false
   configmap: false
   ingress: false
+  coreevent: false
   event: true
 slack:
   channel: '#YOUR_CHANNEL'
@@ -148,6 +149,7 @@ resource:
   secret: false
   configmap: false
   ingress: false
+  coreevent: false
   event: true
 ```
 
@@ -344,6 +346,7 @@ data:
       serviceaccount: false
       services: true
       event: true
+      coreevent: false
     ```
 
 ### flock:
@@ -426,6 +429,7 @@ resource:
   configmap: false
   ingress: false
   event: true
+  coreevent: false
 namespace: ""
 
 ```
@@ -467,6 +471,7 @@ Flags:
       --sa                      watch for service accounts
       --secret                  watch for plain secrets
       --svc                     watch for services
+      --coreevent               watch for events from the kubernetes core api. (Old events api, replaced in kubernetes 1.19)
 
 Use "kubewatch resource [command] --help" for more information about a command.
 
@@ -501,6 +506,7 @@ Global Flags:
       --sa                      watch for service accounts
       --secret                  watch for plain secrets
       --svc                     watch for services
+      --coreevent               watch for events from the kubernetes core api. (Old events api, replaced in kubernetes 1.19)
 
 ```
 

cmd/resource.go

@@ -149,6 +149,10 @@ func configureResource(operation string, cmd *cobra.Command, conf *config.Config
 			"statefulset",
 			&conf.Resource.StatefulSet,
 		},
+		{
+			"coreevent",
+			&conf.Resource.CoreEvent,
+		},
 	}
 
 	for _, flag := range flags {
@@ -197,4 +201,5 @@ func init() {
 	resourceConfigCmd.PersistentFlags().Bool("clusterrole", false, "watch for cluster roles")
 	resourceConfigCmd.PersistentFlags().Bool("clusterrolebinding", false, "watch for cluster roles binding")
 	resourceConfigCmd.PersistentFlags().Bool("sa", false, "watch for service accounts")
+	resourceConfigCmd.PersistentFlags().Bool("coreevent", false, "watch for events (old events object)")
 }

config/config.go

@@ -70,6 +70,7 @@ type Resource struct {
 	Ingress               bool `json:"ing"`
 	HPA                   bool `json:"hpa"`
 	Event                 bool `json:"event"`
+	CoreEvent             bool `json:"coreevent"`
 }
 
 // Config struct contains kubewatch configuration

examples/conf/kubewatch.conf.flock.yaml

@@ -12,3 +12,4 @@ resource:
   persistentvolume: false
   ingress: false
   event: false
+  coreevent: false

examples/conf/kubewatch.conf.hipchat.yaml

@@ -14,3 +14,4 @@ resource:
   persistentvolume: false
   ingress: false
   event: false
+  coreevent: false

examples/conf/kubewatch.conf.mattermost.yaml

@@ -14,3 +14,4 @@ resource:
   persistentvolume: false
   ingress: false
   event: false
+  coreevent: false

kubewatch-configmap.yaml

@@ -20,4 +20,5 @@ data:
       secret: false
       configmap: false
       hpa: false
+      coreevent: false
       event: true

pkg/controller/controller.go

@@ -97,6 +97,30 @@ func Start(conf *config.Config, eventHandler handlers.Handler) {
 	}
 
 	// User Configured Events
+	if conf.Resource.CoreEvent {
+		allCoreEventsInformer := cache.NewSharedIndexInformer(
+			&cache.ListWatch{
+				ListFunc: func(options meta_v1.ListOptions) (runtime.Object, error) {
+					options.FieldSelector = ""
+					return kubeClient.CoreV1().Events(conf.Namespace).List(context.Background(), options)
+				},
+				WatchFunc: func(options meta_v1.ListOptions) (watch.Interface, error) {
+					options.FieldSelector = ""
+					return kubeClient.CoreV1().Events(conf.Namespace).Watch(context.Background(), options)
+				},
+			},
+			&events_v1.Event{},
+			0, //Skip resync
+			cache.Indexers{},
+		)
+
+		allCoreEventsController := newResourceController(kubeClient, eventHandler, allCoreEventsInformer, objName(api_v1.Event{}), V1)
+		stopAllCoreEventsCh := make(chan struct{})
+		defer close(stopAllCoreEventsCh)
+
+		go allCoreEventsController.Run(stopAllCoreEventsCh)
+	}
+
 	if conf.Resource.Event {
 		allEventsInformer := cache.NewSharedIndexInformer(
 			&cache.ListWatch{

pkg/utils/k8sutil.go

@@ -98,6 +98,8 @@ func GetObjectMetaData(obj interface{}) (objectMeta meta_v1.ObjectMeta) {
 		objectMeta = object.ObjectMeta
 	case *api_v1.ConfigMap:
 		objectMeta = object.ObjectMeta
+	case *api_v1.Event:
+		objectMeta = object.ObjectMeta
 	case *events_v1.Event:
 		objectMeta = object.ObjectMeta
 	}