feat: minify event data and expose etcd client timeout

Author: lucasepe

eventrouter/echo.py

@@ -0,0 +1,15 @@
+from http.server import BaseHTTPRequestHandler, HTTPServer
+
+class Handler(BaseHTTPRequestHandler):
+    def do_POST(self):
+        length = int(self.headers.get('Content-Length'))
+        body = self.rfile.read(length)
+        print("=== RECEIVED POST ===")
+        print(body.decode('utf-8'))
+        print("======================")
+        self.send_response(200)
+        self.end_headers()
+
+httpd = HTTPServer(("0.0.0.0", 9092), Handler)
+print("Listening on :9092")
+httpd.serve_forever()

eventrouter/internal/router/handler.go

@@ -71,21 +71,19 @@ func (c *pusher) Handle(evt corev1.Event) {
 		return
 	}
 
-	if len(evt.ManagedFields) == 0 {
-		evt.ManagedFields = nil
-	}
+	out := minifyEvent(evt)
 
-	labels := evt.GetLabels()
+	labels := out.GetLabels()
 	if labels == nil {
 		labels = map[string]string{
 			keyCompositionID: compositionId,
 		}
 	} else {
 		labels[keyCompositionID] = compositionId
 	}
-	evt.SetLabels(labels)
+	out.SetLabels(labels)
 
-	c.notifyAll(all, evt)
+	c.notifyAll(all, out)
 }
 
 func (c *pusher) notifyAll(all map[string]v1alpha1.RegistrationSpec, evt corev1.Event) {

eventrouter/internal/router/minify.go

@@ -0,0 +1,49 @@
+package router
+
+import (
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+func minifyEvent(e corev1.Event) corev1.Event {
+	out := corev1.Event{
+		TypeMeta: metav1.TypeMeta{
+			Kind:       "Event",
+			APIVersion: "v1",
+		},
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      e.ObjectMeta.Name,
+			Namespace: e.ObjectMeta.Namespace,
+			Labels:    e.ObjectMeta.Labels,
+		},
+		Reason:  e.Reason,
+		Message: e.Message,
+		Type:    e.Type,
+	}
+
+	// EventTime può rimanere
+	out.EventTime = e.EventTime
+
+	// Timestamp legacy azzerati
+	out.FirstTimestamp = metav1.Time{}
+	out.LastTimestamp = metav1.Time{}
+
+	// Source vuoto
+	out.Source = corev1.EventSource{}
+
+	// InvolvedObject leggero
+	out.InvolvedObject = corev1.ObjectReference{
+		Kind:      e.InvolvedObject.Kind,
+		Namespace: e.InvolvedObject.Namespace,
+		Name:      e.InvolvedObject.Name,
+		UID:       e.InvolvedObject.UID,
+	}
+
+	// Rimuovi campi rumorosi
+	out.ReportingController = ""
+	out.ReportingInstance = ""
+	out.Action = ""
+	out.ManagedFields = nil
+
+	return out
+}

eventrouter/manifests/deployment.yaml

@@ -23,9 +23,10 @@ spec:
         image: kind.local/eventrouter:latest
         imagePullPolicy: Never
         args:
+          - --namespace=demo-system
           - --insecure=true
           - --debug=true
-          - --v=6
+          - --v=4
         securityContext:
           allowPrivilegeEscalation: false
           readOnlyRootFilesystem: false

eventrouter/scripts/1.kind-up.sh

@@ -0,0 +1,13 @@
+#!/bin/bash
+
+
+kind get kubeconfig >/dev/null 2>&1 || \
+    cat <<EOF | kind create cluster --config=-
+kind: Cluster
+apiVersion: kind.x-k8s.io/v1alpha4
+nodes:
+- role: control-plane
+  extraPortMappings:
+    - containerPort: 9091   # porta del server echo nel pod
+      hostPort: 9091        # porta sul tuo Mac
+EOF

eventrouter/scripts/build.sh eventrouter/scripts/2.build.sheventrouter/scripts/build.sh renamed to eventrouter/scripts/2.build.sh

@@ -9,3 +9,6 @@ kubectl apply -f manifests/sa.yaml
 kubectl apply -f manifests/rbac.yaml
 kubectl apply -f manifests/rbac-bind.yaml
 kubectl apply -f manifests/deployment.yaml
+
+
+kubectl apply -f testdata/registration.sample.yaml

eventrouter/scripts/install.sh eventrouter/scripts/3.install.sheventrouter/scripts/install.sh renamed to eventrouter/scripts/3.install.sh

@@ -0,0 +1,25 @@
+#!/bin/bash
+
+
+cat <<EOF > echo.py
+from http.server import BaseHTTPRequestHandler, HTTPServer
+
+class Handler(BaseHTTPRequestHandler):
+    def do_POST(self):
+        length = int(self.headers.get('Content-Length'))
+        body = self.rfile.read(length)
+        print("=== RECEIVED POST ===")
+        print(body.decode('utf-8'))
+        print("======================")
+        self.send_response(200)
+        self.end_headers()
+
+httpd = HTTPServer(("0.0.0.0", 9092), Handler)
+print("Listening on :9092")
+httpd.serve_forever()
+EOF
+
+python3 echo.py
+
+rm echo.py
+

eventrouter/scripts/4.run-handler.sh

@@ -1,7 +1,7 @@
 apiVersion: eventrouter.krateo.io/v1alpha1
 kind: Registration
 metadata:
-  name: httpecho-registration
+  name: eventrouter-echo
 spec:
-  serviceName: HTTP Echo
-  endpoint: http://127.0.0.1:9090/handle
+  serviceName: EventRouter Echo
+  endpoint: http://127.0.0.1:9092/handle