diff --git a/lib/encoding/compress.go b/lib/encoding/compress.go index 08f196500..95907800c 100644 --- a/lib/encoding/compress.go +++ b/lib/encoding/compress.go @@ -10,6 +10,7 @@ import ( // // The given compressLevel is used for the compression. func CompressZSTDLevel(dst, src []byte, compressLevel int) []byte { + compressCalls.Inc() originalBytes.Add(len(src)) dstLen := len(dst) dst = gozstd.CompressLevel(dst, src, compressLevel) @@ -20,10 +21,14 @@ func CompressZSTDLevel(dst, src []byte, compressLevel int) []byte { // DecompressZSTD decompresses src, appends the result to dst and returns // the appended dst. func DecompressZSTD(dst, src []byte) ([]byte, error) { + decompressCalls.Inc() return gozstd.Decompress(dst, src) } var ( + compressCalls = metrics.NewCounter(`vm_zstd_block_compress_calls_total`) + decompressCalls = metrics.NewCounter(`vm_zstd_block_decompress_calls_total`) + originalBytes = metrics.NewCounter(`vm_zstd_block_original_bytes_total`) compressedBytes = metrics.NewCounter(`vm_zstd_block_compressed_bytes_total`) )