MCPcopy
hub / github.com/segmentio/kafka-go / NewReader

Method NewReader

compress/compress.go:97–97  ·  view source on GitHub ↗

Constructs a new reader which decompresses data from r.

(r io.Reader)

Source from the content-addressed store, hash-verified

95
96 // Constructs a new reader which decompresses data from r.
97 NewReader(r io.Reader) io.ReadCloser
98
99 // Constructs a new writer which writes compressed data to w.
100 NewWriter(w io.Writer) io.WriteCloser

Callers 15

TestSaramaCompatibilityFunction · 0.65
TestMemberMetadataFunction · 0.65
TestJoinGroupResponseFunction · 0.65
TestProtocolFunction · 0.65
TestSASLAuthenticateRequestV0Function · 0.65
TestSASLAuthenticateResponseV0Function · 0.65
TestOffsetFetchResponseV1Function · 0.65
decodeMemberMetadataFunction · 0.65
decodeMemberAssignmentsFunction · 0.65
mustCompressFunction · 0.65
TestDiscardNFunction · 0.65
TestMessageFixturesFunction · 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 15

TestSaramaCompatibilityFunction · 0.52
TestMemberMetadataFunction · 0.52
TestJoinGroupResponseFunction · 0.52
TestProtocolFunction · 0.52
TestSASLAuthenticateRequestV0Function · 0.52
TestSASLAuthenticateResponseV0Function · 0.52
TestOffsetFetchResponseV1Function · 0.52
mustCompressFunction · 0.52
TestDiscardNFunction · 0.52
TestMessageFixturesFunction · 0.52
newReaderHelperFunction · 0.52
TestCreateTopicsResponseFunction · 0.52