From 21f2f746abc1a5a1b3193274401f5728e19cc26f Mon Sep 17 00:00:00 2001 From: Damien Grisonnet Date: Fri, 9 Sep 2022 19:16:40 +0200 Subject: [PATCH] event_broadcaster: update isomorphic event def Update the definition of an isomorphic event in the events/v1 client to match the aggregation logic that was already present in the core/v1 implementation. The note field was omitted even though the message was used in the core API aggregation because we didn't reach consensus. Signed-off-by: Damien Grisonnet --- .../src/k8s.io/client-go/tools/events/event_broadcaster.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/staging/src/k8s.io/client-go/tools/events/event_broadcaster.go b/staging/src/k8s.io/client-go/tools/events/event_broadcaster.go index e62d2cced04..9f18ce45db1 100644 --- a/staging/src/k8s.io/client-go/tools/events/event_broadcaster.go +++ b/staging/src/k8s.io/client-go/tools/events/event_broadcaster.go @@ -56,9 +56,11 @@ var defaultSleepDuration = 10 * time.Second // TODO: validate impact of copying and investigate hashing type eventKey struct { + eventType string action string reason string reportingController string + reportingInstance string regarding corev1.ObjectReference related corev1.ObjectReference } @@ -289,9 +291,11 @@ func createPatchBytesForSeries(event *eventsv1.Event) ([]byte, error) { func getKey(event *eventsv1.Event) eventKey { key := eventKey{ + eventType: event.Type, action: event.Action, reason: event.Reason, reportingController: event.ReportingController, + reportingInstance: event.ReportingInstance, regarding: event.Regarding, } if event.Related != nil {