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

Method Compression

protocol/record.go:25–27  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

23)
24
25func (a Attributes) Compression() compress.Compression {
26 return compress.Compression(a & 7)
27}
28
29func (a Attributes) Transactional() bool {
30 return (a & Transactional) != 0

Callers 8

StringMethod · 0.95
readFromVersion1Method · 0.80
writeToVersion1Method · 0.80
readFromVersion2Method · 0.80
writeToVersion2Method · 0.80
testEncodeDecodeFunction · 0.80
testCompressedMessagesFunction · 0.80
TestMixedCompressedMessagesFunction · 0.80

Calls 1

CompressionTypeAlias · 0.92

Tested by 3

testEncodeDecodeFunction · 0.64
testCompressedMessagesFunction · 0.64
TestMixedCompressedMessagesFunction · 0.64