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

Function closeProducer

helpers_test.go:62–64  ·  view source on GitHub ↗
(t *testing.T, p AsyncProducer)

Source from the content-addressed store, hash-verified

60}
61
62func closeProducer(t *testing.T, p AsyncProducer) {
63 closeProducerWithTimeout(t, p, 5*time.Minute)
64}
65
66const TestMessage = "ABC THE MESSAGE"
67

Callers 15

TestAsyncProducerRemoteBrokerClosedFunction · 0.85
TestAsyncProducerFunction · 0.85
TestAsyncProducerMultipleFlushesFunction · 0.85
TestAsyncProducerMultipleBrokersFunction · 0.85
TestAsyncProducerCustomPartitionerFunction · 0.85
TestAsyncProducerFailureRetryFunction · 0.85
TestAsyncProducerRecoveryWithRetriesDisabledFunction · 0.85
TestAsyncProducerEncoderFailuresFunction · 0.85
TestAsyncProducerBrokerBounceFunction · 0.85
TestAsyncProducerBrokerBounceWithStaleMetadataFunction · 0.85
TestAsyncProducerMultipleRetriesFunction · 0.85
TestAsyncProducerMultipleRetriesWithBackoffFuncFunction · 0.85

Calls 1

closeProducerWithTimeoutFunction · 0.85

Tested by

no test coverage detected