From e172a00fcdc6ec62c0347d7f872bd720cb339c81 Mon Sep 17 00:00:00 2001 From: Denys Zhdanov Date: Fri, 6 Sep 2024 19:59:42 +0200 Subject: [PATCH] Adding S2 compression --- receiver/tcp/tcp.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/receiver/tcp/tcp.go b/receiver/tcp/tcp.go index 09f3883ae..74e9c1273 100644 --- a/receiver/tcp/tcp.go +++ b/receiver/tcp/tcp.go @@ -17,6 +17,7 @@ import ( "github.com/go-graphite/go-carbon/receiver" "github.com/go-graphite/go-carbon/receiver/parse" "github.com/klauspost/compress/gzip" + "github.com/klauspost/compress/s2" "github.com/klauspost/compress/snappy" "github.com/lomik/graphite-pickle/framing" "github.com/lomik/zapwriter" @@ -395,6 +396,10 @@ type decompressor func(net.Conn) (io.Reader, error) func newDecompressor(typ string) decompressor { switch typ { + case "s2": + return func(c net.Conn) (io.Reader, error) { + return s2.NewReader(c), nil + } case "snappy": return func(c net.Conn) (io.Reader, error) { return snappy.NewReader(c), nil