MCPcopy
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
469func (b *MockBroker) Returns(e encoderWithHeader) {
470 b.expectations <- e
471}

Callers 15

TestSyncProducerFunction · 0.95
TestSyncProducerTransactionalFunction · 0.95
TestSyncProducerBatchFunction · 0.95
TestConcurrentSyncProducerFunction · 0.95
TestSyncProducerToNonExistingTopicFunction · 0.95
TestSyncProducerRecoveryWithRetriesDisabledFunction · 0.95
TestSimpleBrokerCommunicationFunction · 0.95
TestBrokerFailedRequestFunction · 0.95
TestAsyncProducerFunction · 0.95
TestAsyncProducerMultipleFlushesFunction · 0.95
TestAsyncProducerMultipleBrokersFunction · 0.95
TestAsyncProducerCustomPartitionerFunction · 0.95

Calls

no outgoing calls

Tested by 15

TestSyncProducerFunction · 0.76
TestSyncProducerTransactionalFunction · 0.76
TestSyncProducerBatchFunction · 0.76
TestConcurrentSyncProducerFunction · 0.76
TestSyncProducerToNonExistingTopicFunction · 0.76
TestSyncProducerRecoveryWithRetriesDisabledFunction · 0.76
TestSimpleBrokerCommunicationFunction · 0.76
TestBrokerFailedRequestFunction · 0.76
TestAsyncProducerFunction · 0.76
TestAsyncProducerMultipleFlushesFunction · 0.76
TestAsyncProducerMultipleBrokersFunction · 0.76
TestAsyncProducerCustomPartitionerFunction · 0.76