Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/segmentio/kafka-go
/ NewWriter
Method
NewWriter
compress/compress.go:100–100 ·
view source on GitHub ↗
Constructs a new writer which writes compressed data to w.
(w io.Writer)
Source
from the content-addressed store, hash-verified
98
99
// Constructs a new writer which writes compressed data to w.
100
NewWriter(w io.Writer) io.WriteCloser
101
}
102
103
var
(
Callers
11
mustCompress
Function · 0.65
NewConnWith
Function · 0.65
compressRecordBatch
Function · 0.65
compressMessageSet
Function · 0.65
writeToVersion1
Method · 0.65
writeToVersion2
Method · 0.65
compress
Function · 0.65
BenchmarkCompression
Function · 0.65
benchmarkCompression
Function · 0.65
NewWriter
Method · 0.65
NewWriter
Method · 0.65
Implementers
5
noopCodec
compress/compress_test.go
Codec
compress/zstd/zstd.go
Codec
compress/lz4/lz4.go
Codec
compress/snappy/snappy.go
Codec
compress/gzip/gzip.go
Calls
no outgoing calls
Tested by
4
mustCompress
Function · 0.52
compress
Function · 0.52
BenchmarkCompression
Function · 0.52
benchmarkCompression
Function · 0.52