Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/IBM/sarama
/ Returns
Method
Returns
mockbroker.go:469–471 ·
view source on GitHub ↗
(e encoderWithHeader)
Source
from the content-addressed store, hash-verified
467
}
468
469
func
(b *MockBroker) Returns(e encoderWithHeader) {
470
b.expectations <- e
471
}
Callers
15
TestSyncProducer
Function · 0.95
TestSyncProducerTransactional
Function · 0.95
TestSyncProducerBatch
Function · 0.95
TestConcurrentSyncProducer
Function · 0.95
TestSyncProducerToNonExistingTopic
Function · 0.95
TestSyncProducerRecoveryWithRetriesDisabled
Function · 0.95
TestSimpleBrokerCommunication
Function · 0.95
TestBrokerFailedRequest
Function · 0.95
TestAsyncProducer
Function · 0.95
TestAsyncProducerMultipleFlushes
Function · 0.95
TestAsyncProducerMultipleBrokers
Function · 0.95
TestAsyncProducerCustomPartitioner
Function · 0.95
Calls
no outgoing calls
Tested by
15
TestSyncProducer
Function · 0.76
TestSyncProducerTransactional
Function · 0.76
TestSyncProducerBatch
Function · 0.76
TestConcurrentSyncProducer
Function · 0.76
TestSyncProducerToNonExistingTopic
Function · 0.76
TestSyncProducerRecoveryWithRetriesDisabled
Function · 0.76
TestSimpleBrokerCommunication
Function · 0.76
TestBrokerFailedRequest
Function · 0.76
TestAsyncProducer
Function · 0.76
TestAsyncProducerMultipleFlushes
Function · 0.76
TestAsyncProducerMultipleBrokers
Function · 0.76
TestAsyncProducerCustomPartitioner
Function · 0.76