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

Method BeginTxn

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

BeginTxn mark current transaction as ready.

()

Source from the content-addressed store, hash-verified

44
45 // BeginTxn mark current transaction as ready.
46 BeginTxn() error
47
48 // CommitTxn commit current transaction.
49 CommitTxn() error

Callers 12

testTxnProduceAndCommitOffsetFunction · 0.65
TestFuncTxnAbortedProduceFunction · 0.65
TestSyncProducerTransactionalFunction · 0.65
BeginTxnMethod · 0.65
TestTxnProduceBumpEpochFunction · 0.65
TestTxnProduceRecordWithCommitFunction · 0.65
TestTxnProduceBatchAddPartitionFunction · 0.65
TestTxnProduceRecordWithAbortFunction · 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 9

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