diff --git a/pkg/controller/cluster/events.go b/pkg/controller/cluster/events.go index 419f9d59b77..4519b596932 100644 --- a/pkg/controller/cluster/events.go +++ b/pkg/controller/cluster/events.go @@ -16,36 +16,11 @@ package cluster import ( "context" - "time" miniov2 "github.com/minio/operator/pkg/apis/minio.min.io/v2" - corev1 "k8s.io/api/core/v1" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/klog/v2" ) // RegisterEvent creates an event for a given tenant func (c *Controller) RegisterEvent(ctx context.Context, tenant *miniov2.Tenant, eventType, reason, message string) { - now := time.Now() - _, err := c.kubeClientSet.CoreV1().Events(tenant.Namespace).Create(ctx, &corev1.Event{ - ObjectMeta: metav1.ObjectMeta{ - GenerateName: "tenant-", - Namespace: tenant.Namespace, - }, - InvolvedObject: tenant.ObjectRef(), - Reason: reason, - Message: message, - Source: corev1.EventSource{ - Component: "minio-operator", - }, - FirstTimestamp: metav1.NewTime(now), - LastTimestamp: metav1.NewTime(now), - - Type: eventType, - - ReportingController: "minio-operator", - }, metav1.CreateOptions{}) - if err != nil { - klog.Errorf("Error registering event: %s", err) - } + c.recorder.Event(tenant, eventType, reason, message) }