|
|
|
|
@ -160,7 +160,7 @@ func ParseRequest(logger log.Logger, userID string, maxRecvMsgSize int, r *http. |
|
|
|
|
for retentionPeriod, size := range retentionToSizeMapping { |
|
|
|
|
retentionHours := RetentionPeriodToString(retentionPeriod) |
|
|
|
|
// Add guard clause to prevent negative values from being passed to Prometheus counters
|
|
|
|
|
if size > 0 { |
|
|
|
|
if size >= 0 { |
|
|
|
|
bytesIngested.WithLabelValues(userID, retentionHours, isAggregatedMetric, policyName).Add(float64(size)) |
|
|
|
|
bytesReceivedStats.Inc(size) |
|
|
|
|
} else { |
|
|
|
|
@ -181,7 +181,7 @@ func ParseRequest(logger log.Logger, userID string, maxRecvMsgSize int, r *http. |
|
|
|
|
retentionHours := RetentionPeriodToString(retentionPeriod) |
|
|
|
|
|
|
|
|
|
// Add guard clause to prevent negative values from being passed to Prometheus counters
|
|
|
|
|
if size > 0 { |
|
|
|
|
if size >= 0 { |
|
|
|
|
structuredMetadataBytesIngested.WithLabelValues(userID, retentionHours, isAggregatedMetric, policyName).Add(float64(size)) |
|
|
|
|
bytesIngested.WithLabelValues(userID, retentionHours, isAggregatedMetric, policyName).Add(float64(size)) |
|
|
|
|
bytesReceivedStats.Inc(size) |
|
|
|
|
|