MCPcopy
hub / github.com/segmentio/kafka-go / Done

Method Done

consumergroup.go:283–285  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

281}
282
283func (c genCtx) Done() <-chan struct{} {
284 return c.gen.done
285}
286
287func (c genCtx) Err() error {
288 select {

Callers 15

TestIssue672Function · 0.80
TestIssue806Function · 0.80
LookupPartitionMethod · 0.80
LookupPartitionsMethod · 0.80
connectTLSMethod · 0.80
sleepFunction · 0.80
waitForTopicFunction · 0.80
prepareReaderFunction · 0.80
TestConsumerGroupWithGroupTopicsMultipleFunction · 0.80
TestReaderReadCompactedMessageFunction · 0.80
roundTripMethod · 0.80
refreshMetadataMethod · 0.80

Calls

no outgoing calls

Tested by 8

TestIssue672Function · 0.64
TestIssue806Function · 0.64
waitForTopicFunction · 0.64
prepareReaderFunction · 0.64
TestConsumerGroupWithGroupTopicsMultipleFunction · 0.64
TestReaderReadCompactedMessageFunction · 0.64
TestGenerationStartsFunctionAfterClosedFunction · 0.64
testBatchQueuePutWakesSleepingGetterFunction · 0.64