diff --git a/CHANGELOG.md b/CHANGELOG.md index 5918e4df52..429fae9183 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -21,6 +21,7 @@ * [CHANGE] Store Gateway: Remove `idle_timeout`, `max_conn_age`, `pool_size`, `min_idle_conns` fields for Redis index cache and caching bucket. #5448 * [CHANGE] Store Gateway: Add flag `-store-gateway.sharding-ring.zone-stable-shuffle-sharding` to enable store gateway to use zone stable shuffle sharding. #5489 * [CHANGE] Bucket Index: Add `series_max_size` and `chunk_max_size` to bucket index. #5489 +* [CHANGE] StoreGateway: Rename `cortex_bucket_store_chunk_pool_returned_bytes_total` and `cortex_bucket_store_chunk_pool_requested_bytes_total` to `cortex_bucket_store_chunk_pool_operation_bytes_total`. #5552 * [CHANGE] Query Frontend/Querier: Make build info API disabled by default and add feature flag `api.build-info-enabled` to enable it. #5533 * [FEATURE] Store Gateway: Add `max_downloaded_bytes_per_request` to limit max bytes to download per store gateway request. * [FEATURE] Added 2 flags `-alertmanager.alertmanager-client.grpc-max-send-msg-size` and ` -alertmanager.alertmanager-client.grpc-max-recv-msg-size` to configure alert manager grpc client message size limits. #5338 diff --git a/pkg/storegateway/chunk_bytes_pool.go b/pkg/storegateway/chunk_bytes_pool.go index e6be1003b9..9972e59c4d 100644 --- a/pkg/storegateway/chunk_bytes_pool.go +++ b/pkg/storegateway/chunk_bytes_pool.go @@ -22,7 +22,7 @@ func newChunkBytesPool(minBucketSize, maxBucketSize int, maxChunkPoolBytes uint6 return &chunkBytesPool{ pool: upstream, poolByteStats: promauto.With(reg).NewCounterVec(prometheus.CounterOpts{ - Name: "cortex_bucket_store_chunk_pool_bytes_total", + Name: "cortex_bucket_store_chunk_pool_operation_bytes_total", Help: "Total bytes number of bytes pooled by operation.", }, []string{"operation", "stats"}), }, nil @@ -34,14 +34,14 @@ func (p *chunkBytesPool) Get(sz int) (*[]byte, error) { return buffer, err } - p.poolByteStats.WithLabelValues("Get", "Requested").Add(float64(sz)) - p.poolByteStats.WithLabelValues("Get", "Cap").Add(float64(cap(*buffer))) + p.poolByteStats.WithLabelValues("get", "requested").Add(float64(sz)) + p.poolByteStats.WithLabelValues("get", "cap").Add(float64(cap(*buffer))) return buffer, err } func (p *chunkBytesPool) Put(b *[]byte) { - p.poolByteStats.WithLabelValues("Put", "Len").Add(float64(len(*b))) - p.poolByteStats.WithLabelValues("Put", "Cap").Add(float64(cap(*b))) + p.poolByteStats.WithLabelValues("put", "len").Add(float64(len(*b))) + p.poolByteStats.WithLabelValues("put", "cap").Add(float64(cap(*b))) p.pool.Put(b) } diff --git a/pkg/storegateway/chunk_bytes_pool_test.go b/pkg/storegateway/chunk_bytes_pool_test.go index 74db90b646..dc8f1e317c 100644 --- a/pkg/storegateway/chunk_bytes_pool_test.go +++ b/pkg/storegateway/chunk_bytes_pool_test.go @@ -31,11 +31,11 @@ func TestChunkBytesPool_Get(t *testing.T) { p.Put(b) assert.NoError(t, testutil.GatherAndCompare(reg, bytes.NewBufferString(fmt.Sprintf(` - # HELP cortex_bucket_store_chunk_pool_bytes_total Total bytes number of bytes pooled by operation. - # TYPE cortex_bucket_store_chunk_pool_bytes_total counter - cortex_bucket_store_chunk_pool_bytes_total{operation="Get",stats="Cap"} %d - cortex_bucket_store_chunk_pool_bytes_total{operation="Get",stats="Requested"} %d - cortex_bucket_store_chunk_pool_bytes_total{operation="Put",stats="Cap"} %d - cortex_bucket_store_chunk_pool_bytes_total{operation="Put",stats="Len"} %d + # HELP cortex_bucket_store_chunk_pool_operation_bytes_total Total bytes number of bytes pooled by operation. + # TYPE cortex_bucket_store_chunk_pool_operation_bytes_total counter + cortex_bucket_store_chunk_pool_operation_bytes_total{operation="get",stats="cap"} %d + cortex_bucket_store_chunk_pool_operation_bytes_total{operation="get",stats="requested"} %d + cortex_bucket_store_chunk_pool_operation_bytes_total{operation="put",stats="cap"} %d + cortex_bucket_store_chunk_pool_operation_bytes_total{operation="put",stats="len"} %d `, store.EstimatedMaxChunkSize*3, store.EstimatedMaxChunkSize*2, store.EstimatedMaxChunkSize*2, len(testBytes))))) }