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

Method CommitTxn

mocks/sync_producer.go:239–245  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

237}
238
239func (sp *SyncProducer) CommitTxn() error {
240 sp.txnLock.Lock()
241 defer sp.txnLock.Unlock()
242
243 sp.txnStatus = sarama.ProducerTxnFlagReady
244 return nil
245}
246
247func (sp *SyncProducer) AbortTxn() error {
248 sp.txnLock.Lock()

Callers 1

TestSyncProducerUseTxnFunction · 0.95

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls

Tested by 1

TestSyncProducerUseTxnFunction · 0.76