Skip to content

Commit

Permalink
refactor: rename recordEventProcessed to recordEventReceived
Browse files Browse the repository at this point in the history
  • Loading branch information
andrzej-stencel committed Jun 28, 2022
1 parent adcb6a6 commit 1d5dd51
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/receiver/rawk8seventsreceiver/receiver.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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
}
Expand Down

0 comments on commit 1d5dd51

Please sign in to comment.