upstream/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2026-02-03 20:39:32 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions 13

use refType instead of any

Browse source 
Signed-off-by: pipiland2612 <nguyen.t.dang.minh@gmail.com>
This commit is contained in:
pipiland2612 2025-11-18 15:30:17 +02:00
parent 7087735b45
commit 9046dbb3fc
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
storage/remote/queue_manager.go
View file

@ -720,8 +720,13 @@ func isV2TimeSeriesOldFilter(metrics *queueManagerMetrics, baseTime time.Time, s
}
}
// refTypes is supported record types that can be appended to the queue manager.
type refTypes interface {
record.RefSample | record.RefExemplar | record.RefHistogramSample | record.RefFloatHistogramSample
}
// appendItemConfig contains configuration for the appendWithRetry helper.
type appendItemConfig[T any] struct {
type appendItemConfig[T refTypes] struct {
// dataTypeName is used for logging (e.g., "sample", "exemplar", "histogram").
dataTypeName string
@ -751,7 +756,7 @@ type appendItemConfig[T any] struct {
// appendWithRetry is a generic helper function that implements the common append logic
// for all data types (samples, exemplars, histograms, float histograms).
// It handles age checking, series lookup, dropped series tracking, and retry logic.
func appendWithRetry[T any](qm *QueueManager, items []T, cfg appendItemConfig[T]) bool {
func appendWithRetry[T refTypes](qm *QueueManager, items []T, cfg appendItemConfig[T]) bool {
// Early return if this data type is not enabled
if !cfg.checkEnabled() {
return true