metadatabatcher

Feb 3, 2026

Changes in this version

+ const MetadataBatchPubsubChannel

+ const UUIDBase64Size

+ func EncodeAgentID(agentID uuid.UUID, dst []byte) error

+ func EncodeAgentIDChunks(agentIDs []uuid.UUID) ([][]byte, error)

+ type Batcher struct

+ Metrics Metrics

+ func NewBatcher(ctx context.Context, reg prometheus.Registerer, store database.Store, ...) (*Batcher, error)

+ func (b *Batcher) Add(agentID uuid.UUID, keys []string, values []string, errors []string, ...) error

+ func (b *Batcher) Close()

+ type Metrics struct

+ BatchSize prometheus.Histogram

+ BatchUtilization prometheus.Histogram

+ BatchesTotal *prometheus.CounterVec

+ DroppedKeysTotal prometheus.Counter

+ FlushDuration *prometheus.HistogramVec

+ MetadataTotal prometheus.Counter

+ PublishErrors prometheus.Counter

+ func NewMetrics() Metrics

+ func (m Metrics) Collectors() []prometheus.Collector

+ type Option func(b *Batcher)

+ func WithBatchSize(size int) Option

+ func WithClock(clock quartz.Clock) Option

+ func WithInterval(d time.Duration) Option

+ func WithLogger(log slog.Logger) Option