Fix linter

RichieSams · Apr 24, 2024 · 154e7cb · 154e7cb
1 parent 76d0a81
commit 154e7cb
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/processor/intervalprocessor/processor.go b/processor/intervalprocessor/processor.go
@@ -163,21 +163,25 @@ func aggregateDataPoints[DPS metrics.DataPointSlice[DP], DP metrics.DataPoint[DP
 
 		existing, ok := state.Load(streamDataPointID)
 		if !ok {
-			state.Store(streamDataPointID, metrics.StreamDataPoint[DP]{
+			if err := state.Store(streamDataPointID, metrics.StreamDataPoint[DP]{
 				Metric:      metric,
 				DataPoint:   dp,
 				LastUpdated: now,
-			})
+			}); err != nil {
+				panic(fmt.Sprintf("Storing state should never panic, because HashMap always returns nil - Err: %v", err))
+			}
 			continue
 		}
 
 		// Check if the datapoint is newer
 		if dp.Timestamp().AsTime().After(existing.DataPoint.Timestamp().AsTime()) {
-			state.Store(streamDataPointID, metrics.StreamDataPoint[DP]{
+			if err := state.Store(streamDataPointID, metrics.StreamDataPoint[DP]{
 				Metric:      metric,
 				DataPoint:   dp,
 				LastUpdated: now,
-			})
+			}); err != nil {
+				panic(fmt.Sprintf("Storing state should never panic, because HashMap always returns nil - Err: %v", err))
+			}
 			continue
 		}