@@ -4242,15 +4242,16 @@ func (sm *StoreMetrics) updateEngineMetrics(m storage.Metrics) {
4242
4242
sm .SSTableRemoteBytes .Update (int64 (size ))
4243
4243
sm .SSTableRemoteCount .Update (int64 (count ))
4244
4244
4245
- // TODO(radu): aggregate blob file compression metrics when those are added.
4246
- sm .CompressionSnappyBytes .Update (int64 (m .Table .Compression .Snappy .CompressedBytes ))
4247
- sm .CompressionSnappyCR .Update (m .Table .Compression .Snappy .CompressionRatio ())
4248
- sm .CompressionMinLZBytes .Update (int64 (m .Table .Compression .MinLZ .CompressedBytes ))
4249
- sm .CompressionMinLZCR .Update (m .Table .Compression .MinLZ .CompressionRatio ())
4250
- sm .CompressionZstdBytes .Update (int64 (m .Table .Compression .Zstd .CompressedBytes ))
4251
- sm .CompressionZstdCR .Update (m .Table .Compression .Zstd .CompressionRatio ())
4252
- sm .CompressionNoneBytes .Update (int64 (m .Table .Compression .NoCompressionBytes ))
4253
- sm .CompressionUnknownBytes .Update (int64 (m .Table .Compression .CompressedBytesWithoutStats ))
4245
+ c := m .Table .Compression
4246
+ c .MergeWith (& m .BlobFiles .Compression )
4247
+ sm .CompressionSnappyBytes .Update (int64 (c .Snappy .CompressedBytes ))
4248
+ sm .CompressionSnappyCR .Update (c .Snappy .CompressionRatio ())
4249
+ sm .CompressionMinLZBytes .Update (int64 (c .MinLZ .CompressedBytes ))
4250
+ sm .CompressionMinLZCR .Update (c .MinLZ .CompressionRatio ())
4251
+ sm .CompressionZstdBytes .Update (int64 (c .Zstd .CompressedBytes ))
4252
+ sm .CompressionZstdCR .Update (c .Zstd .CompressionRatio ())
4253
+ sm .CompressionNoneBytes .Update (int64 (c .NoCompressionBytes ))
4254
+ sm .CompressionUnknownBytes .Update (int64 (c .CompressedBytesWithoutStats ))
4254
4255
4255
4256
overall := pebble.CompressionStatsForSetting {
4256
4257
CompressedBytes : m .Table .Compression .NoCompressionBytes ,
0 commit comments