add kube events

Signed-off-by: Markus Blaschke <[email protected]>

Author: mblaschke

kube_janitor/kube.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"fmt"
 	"strings"
+	"time"
 
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -117,3 +118,38 @@ func (j *Janitor) kubeEachResource(ctx context.Context, gvr schema.GroupVersionR
 
 	return nil
 }
+
+func (j *Janitor) kubeCreateEventFromResource(ctx context.Context, namespace string, resource unstructured.Unstructured, message, reason string) error {
+	timestamp := metav1.Time{Time: time.Now()}
+
+	event := corev1.Event{
+		ObjectMeta: metav1.ObjectMeta{
+			GenerateName: "kube-janitor-",
+			Namespace:    resource.GetNamespace(),
+		},
+		ReportingInstance: "kube-janitor",
+		InvolvedObject: corev1.ObjectReference{
+			APIVersion: resource.GetAPIVersion(),
+			Kind:       resource.GetKind(),
+			Namespace:  resource.GetNamespace(),
+			Name:       resource.GetName(),
+			UID:        resource.GetUID(),
+		},
+		Reason:  reason,
+		Message: message,
+		Source: corev1.EventSource{
+			Component: "kube-janitor",
+		},
+		FirstTimestamp:      timestamp,
+		LastTimestamp:       timestamp,
+		Count:               1,
+		Type:                "Normal",
+		Series:              nil,
+		Action:              "Deleted",
+		Related:             nil,
+		ReportingController: "kube-janitor",
+	}
+
+	_, err := j.kubeClient.CoreV1().Events(namespace).Create(ctx, &event, metav1.CreateOptions{})
+	return err
+}

kube_janitor/task.common.go

@@ -3,6 +3,7 @@ package kube_janitor
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"log/slog"
 
 	jmespath "github.com/jmespath-community/go-jmespath"
@@ -91,6 +92,13 @@ func (j *Janitor) checkResourceTtlAndTriggerDeleteIfExpired(ctx context.Context,
 			if err != nil {
 				return err
 			}
+
+			reason := "TimeToLiveExpired"
+			message := fmt.Sprintf(`TTL of "%v" is expired and resource is being deleted`, ttlValue)
+			err = j.kubeCreateEventFromResource(ctx, resource.GetNamespace(), resource, message, reason)
+			if err != nil {
+				resourceLogger.Error("unable to create Kubernetes Event", slog.Any("error", err))
+			}
 		}
 	}