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

Method Read

utils.go:112–114  ·  view source on GitHub ↗
(b []byte)

Source from the content-addressed store, hash-verified

110}
111
112func (bc *bufConn) Read(b []byte) (n int, err error) {
113 return bc.buf.Read(b)
114}
115
116// KafkaVersion instances represent versions of the upstream Kafka broker.
117type KafkaVersion struct {

Callers 4

TestNewHashPartitionerWithHasherFunction · 0.80
TestHashPartitionerFunction · 0.80
TestWithCustomFallbackPartitionerFunction · 0.80
generateMessagesFunction · 0.80

Calls

no outgoing calls

Tested by 3

TestNewHashPartitionerWithHasherFunction · 0.64
TestHashPartitionerFunction · 0.64
TestWithCustomFallbackPartitionerFunction · 0.64