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

Method Done

broker.go:128–128  ·  view source on GitHub ↗

Done should return true when the SCRAM conversation is over.

()

Source from the content-addressed store, hash-verified

126 // Done should return true when the SCRAM conversation
127 // is over.
128 Done() bool
129}
130
131type responsePromise struct {

Callers 15

TestConsumerGroupDeadlockFunction · 0.65
produceMsgsFunction · 0.65
consumeMsgsFunction · 0.65
closeProducerWithTimeoutFunction · 0.65
responseFeederMethod · 0.65
subscriptionConsumerMethod · 0.65
TestFuncMultiPartitionProduceFunction · 0.65
handleSuccessesMethod · 0.65
handleErrorsMethod · 0.65
TestAsyncProducerBrokerRestartFunction · 0.65
sendAndReceiveSASLSCRAMv0Method · 0.65
sendAndReceiveSASLSCRAMv1Method · 0.65

Implementers 2

MockSCRAMClientbroker_test.go
XDGSCRAMClientexamples/sasl_scram_client/scram_clien

Calls

no outgoing calls

Tested by 15

TestConsumerGroupDeadlockFunction · 0.52
produceMsgsFunction · 0.52
consumeMsgsFunction · 0.52
closeProducerWithTimeoutFunction · 0.52
TestFuncMultiPartitionProduceFunction · 0.52
TestAsyncProducerBrokerRestartFunction · 0.52
TestMetadataRefreshConcurrencyFunction · 0.52
TestClientUpdateMetadataErrorAndRetryFunction · 0.52
TestClientRefreshesMetadataConcurrentlyFunction · 0.52
produceWithJavaFunction · 0.52
consumeWithSaramaFunction · 0.52
consumeWithJavaFunction · 0.52