From 6b0ae332f8f89fc175061eda1c8f39c64fc34880 Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Fri, 24 May 2019 13:01:02 +0300 Subject: [PATCH] lib/encoding: add `vm_zstd_block_{compress|decompress}_calls_total` for determining the number CompressZSTD / DecompressZSTD calls --- lib/encoding/compress.go | 5 +++++ 1 file changed, 5 insertions(+) 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`) )