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

Method CommitTxn

sync_producer.go:49–49  ·  view source on GitHub ↗

CommitTxn commit current transaction.

()

Source from the content-addressed store, hash-verified

47
48 // CommitTxn commit current transaction.
49 CommitTxn() error
50
51 // AbortTxn abort current transaction.
52 AbortTxn() error

Callers 10

testTxnProduceAndCommitOffsetFunction · 0.65
TestSyncProducerTransactionalFunction · 0.65
CommitTxnMethod · 0.65
TestTxnProduceBumpEpochFunction · 0.65
TestTxnProduceRecordWithCommitFunction · 0.65
TestTxnProduceBatchAddPartitionFunction · 0.65
TestTxnCanAbortFunction · 0.65
TestProducerWithTxnFunction · 0.65
produceTestRecordFunction · 0.65
ConsumeClaimMethod · 0.65

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls

Tested by 7

testTxnProduceAndCommitOffsetFunction · 0.52
TestSyncProducerTransactionalFunction · 0.52
TestTxnProduceBumpEpochFunction · 0.52
TestTxnProduceRecordWithCommitFunction · 0.52
TestTxnProduceBatchAddPartitionFunction · 0.52
TestTxnCanAbortFunction · 0.52
TestProducerWithTxnFunction · 0.52