From 1d5dd5159cfdf498c540824e2459f8864830da1f Mon Sep 17 00:00:00 2001 From: Andrzej Stencel Date: Tue, 28 Jun 2022 14:36:31 +0200 Subject: [PATCH] refactor: rename recordEventProcessed to recordEventReceived --- pkg/receiver/rawk8seventsreceiver/receiver.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/receiver/rawk8seventsreceiver/receiver.go b/pkg/receiver/rawk8seventsreceiver/receiver.go index 43cfbbdb2b..af0e054aab 100644 --- a/pkg/receiver/rawk8seventsreceiver/receiver.go +++ b/pkg/receiver/rawk8seventsreceiver/receiver.go @@ -268,7 +268,7 @@ func (r *rawK8sEventsReceiver) processEventChangeLoop() { // this includes: checking if we should process the event, converting it into a plog.Logs // and sending it to the next consumer in the pipeline func (r *rawK8sEventsReceiver) processEventChange(ctx context.Context, eventChange *eventChange) { - r.recordEventProcessed(eventChange.event) + r.recordEventReceived(eventChange.event) if !r.isEventAccepted(eventChange.event) { r.logger.Debug("skipping event, too old", zap.Any("event", eventChange.event)) return @@ -288,7 +288,7 @@ func (r *rawK8sEventsReceiver) processEventChange(ctx context.Context, eventChan } } -func (r *rawK8sEventsReceiver) recordEventProcessed(event *corev1.Event) { +func (r *rawK8sEventsReceiver) recordEventReceived(event *corev1.Event) { if r.storage == nil { return }