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

Method CommitTxn

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

CommitTxn commit current transaction.

()

Source from the content-addressed store, hash-verified

75
76 // CommitTxn commit current transaction.
77 CommitTxn() error
78
79 // AbortTxn abort current transaction.
80 AbortTxn() error

Callers 5

TestFuncTxnCommitNoMessagesFunction · 0.95
TestFuncTxnProduceFunction · 0.95
TestFuncTxnProduceWithBrokerFailureFunction · 0.95
TestFuncTxnProduceEpochBumpFunction · 0.95
TestFuncTxnProduceMultiTxnFunction · 0.95

Implementers 2

asyncProducerasync_producer.go
AsyncProducermocks/async_producer.go

Calls

no outgoing calls

Tested by 5

TestFuncTxnCommitNoMessagesFunction · 0.76
TestFuncTxnProduceFunction · 0.76
TestFuncTxnProduceWithBrokerFailureFunction · 0.76
TestFuncTxnProduceEpochBumpFunction · 0.76
TestFuncTxnProduceMultiTxnFunction · 0.76