MCPcopy
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
103var (

Callers 11

mustCompressFunction · 0.65
NewConnWithFunction · 0.65
compressRecordBatchFunction · 0.65
compressMessageSetFunction · 0.65
writeToVersion1Method · 0.65
writeToVersion2Method · 0.65
compressFunction · 0.65
BenchmarkCompressionFunction · 0.65
benchmarkCompressionFunction · 0.65
NewWriterMethod · 0.65
NewWriterMethod · 0.65

Implementers 5

noopCodeccompress/compress_test.go
Codeccompress/zstd/zstd.go
Codeccompress/lz4/lz4.go
Codeccompress/snappy/snappy.go
Codeccompress/gzip/gzip.go

Calls

no outgoing calls

Tested by 4

mustCompressFunction · 0.52
compressFunction · 0.52
BenchmarkCompressionFunction · 0.52
benchmarkCompressionFunction · 0.52