MCPcopy
hub / github.com/IBM/sarama / getZstdEncoder

Function getZstdEncoder

zstd.go:62–69  ·  view source on GitHub ↗
(params ZstdEncoderParams)

Source from the content-addressed store, hash-verified

60}
61
62func getZstdEncoder(params ZstdEncoderParams) *zstd.Encoder {
63 select {
64 case enc := <-getZstdEncoderChannel(params):
65 return enc
66 default:
67 return newZstdEncoder(params)
68 }
69}
70
71func releaseEncoder(params ZstdEncoderParams, enc *zstd.Encoder) {
72 select {

Callers 2

zstdCompressFunction · 0.85

Calls 2

getZstdEncoderChannelFunction · 0.85
newZstdEncoderFunction · 0.85

Tested by 1