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

Function newBrokerSubscription

consumer.go:415–420  ·  view source on GitHub ↗
(child *partitionConsumer)

Source from the content-addressed store, hash-verified

413}
414
415func newBrokerSubscription(child *partitionConsumer) *brokerSubscription {
416 return &brokerSubscription{
417 child: child,
418 released: make(chan none),
419 }
420}
421
422func (s *brokerSubscription) release() {
423 s.releaseOnce.Do(func() {

Callers 6

ConsumePartitionMethod · 0.85
dispatchMethod · 0.85
TestPartitionConsumerBrokerRaceFunction · 0.85
TestPartitionConsumerDispatcherOrphanedCloseFunction · 0.85
TestConsumerQueueSubscriptionAfterUnrefFunction · 0.85
TestConsumerAbortNoGoroutineLeakFunction · 0.85

Calls

no outgoing calls

Tested by 4

TestPartitionConsumerBrokerRaceFunction · 0.68
TestPartitionConsumerDispatcherOrphanedCloseFunction · 0.68
TestConsumerQueueSubscriptionAfterUnrefFunction · 0.68
TestConsumerAbortNoGoroutineLeakFunction · 0.68