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

Method Context

consumer_group.go:876–876  ·  view source on GitHub ↗

Context returns the session context.

()

Source from the content-addressed store, hash-verified

874
875 // Context returns the session context.
876 Context() context.Context
877}
878
879type consumerGroupSession struct {

Callers 9

consumeKeyedFromPartitionFunction · 0.65
ConsumeClaimMethod · 0.65
ConsumeClaimMethod · 0.65
TestConsumerGroupSessionCancelCause_RebalanceFunction · 0.65
TestConsumerGroupReasonFunction · 0.65
ConsumeClaimMethod · 0.65
ConsumeClaimMethod · 0.65
ConsumeClaimMethod · 0.65
ConsumeClaimMethod · 0.65

Implementers 1

consumerGroupSessionconsumer_group.go

Calls

no outgoing calls

Tested by 6

consumeKeyedFromPartitionFunction · 0.52
ConsumeClaimMethod · 0.52
ConsumeClaimMethod · 0.52
TestConsumerGroupSessionCancelCause_RebalanceFunction · 0.52
TestConsumerGroupReasonFunction · 0.52
ConsumeClaimMethod · 0.52