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

Method Input

async_producer.go:53–53  ·  view source on GitHub ↗

Input is the input channel for the user to write messages to that they wish to send.

()

Source from the content-addressed store, hash-verified

51 // Input is the input channel for the user to write messages to that they
52 // wish to send.
53 Input() chan<- *ProducerMessage
54
55 // Successes is the success output channel back to the user when Return.Successes is
56 // enabled. If Return.Successes is true, you MUST read from this channel or the

Implementers 2

asyncProducerasync_producer.go
AsyncProducermocks/async_producer.go

Calls

no outgoing calls