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

Method feed

async_producer_test.go:121–123  ·  view source on GitHub ↗
(partition int32)

Source from the content-addressed store, hash-verified

119}
120
121func (p testPartitioner) feed(partition int32) {
122 p <- &partition
123}
124
125type flakyEncoder bool
126

Callers 1

TestAsyncProducerCustomPartitionerFunction · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected