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

Method SendMessages

sync_producer.go:32–32  ·  sync_producer.go::SyncProducer.SendMessages

SendMessages produces a given set of messages, and returns only when all messages in the set have either succeeded or failed. Note that messages can succeed and fail individually; if some succeed and some fail, SendMessages will return an error.

(msgs []*ProducerMessage)

Source from the content-addressed store, hash-verified

30 // can succeed and fail individually; if some succeed and some fail,
31 // SendMessages will return an error.
32 SendMessages(msgs []*ProducerMessage) error
33
34 // Close shuts down the producer; you must call this function before a producer
35 // object passes out of scope, as it may otherwise leak memory.

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls