diff --git a/storage/metric/instrumentation.go b/storage/metric/instrumentation.go index dbef506ba0..eb08b6c500 100644 --- a/storage/metric/instrumentation.go +++ b/storage/metric/instrumentation.go @@ -72,6 +72,7 @@ var ( storageOperationDurations = prometheus.NewCounter() storageLatency = prometheus.NewHistogram(diskLatencyHistogram) queueSizes = prometheus.NewGauge() + storedSamplesCount = prometheus.NewCounter() ) func recordOutcome(duration time.Duration, err error, success, failure map[string]string) { @@ -94,4 +95,5 @@ func init() { prometheus.Register("curation_filter_operations_total", "The number of curation filter operations completed.", prometheus.NilLabels, curationFilterOperations) prometheus.Register("curation_duration_ms_total", "The total time spent in curation (ms).", prometheus.NilLabels, curationDuration) prometheus.Register("curation_durations_ms", "Histogram of time spent in curation (ms).", prometheus.NilLabels, curationDurations) + prometheus.Register("prometheus_stored_samples_total", "The number of samples that have been stored.", prometheus.NilLabels, storedSamplesCount) } diff --git a/storage/metric/tiered.go b/storage/metric/tiered.go index 4088427f97..86bbe6ede2 100644 --- a/storage/metric/tiered.go +++ b/storage/metric/tiered.go @@ -21,6 +21,7 @@ import ( "time" "github.com/golang/glog" + "github.com/prometheus/client_golang/prometheus" clientmodel "github.com/prometheus/client_golang/model" @@ -168,6 +169,7 @@ func (t *TieredStorage) AppendSamples(samples clientmodel.Samples) (err error) { } t.memoryArena.AppendSamples(samples) + storedSamplesCount.IncrementBy(prometheus.NilLabels, float64(len(samples))) return }