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

Method BeginTxn

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

BeginTxn mark current transaction as ready.

()

Source from the content-addressed store, hash-verified

72
73 // BeginTxn mark current transaction as ready.
74 BeginTxn() error
75
76 // CommitTxn commit current transaction.
77 CommitTxn() 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