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

Method TxnStatus

mocks/sync_producer.go:255–257  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

253}
254
255func (sp *SyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag {
256 return sp.txnStatus
257}
258
259func (sp *SyncProducer) AddOffsetsToTxn(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string) error {
260 return nil

Callers 1

TestSyncProducerUseTxnFunction · 0.95

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls

Tested by 1

TestSyncProducerUseTxnFunction · 0.76