| 877 | } |
| 878 | |
| 879 | type consumerGroupSession struct { |
| 880 | parent *consumerGroup |
| 881 | memberID string |
| 882 | generationID int32 |
| 883 | handler ConsumerGroupHandler |
| 884 | |
| 885 | claims map[string][]int32 |
| 886 | offsets *offsetManager |
| 887 | ctx context.Context |
| 888 | cancel context.CancelCauseFunc |
| 889 | |
| 890 | waitGroup sync.WaitGroup |
| 891 | releaseOnce sync.Once |
| 892 | hbDying, hbDead chan none |
| 893 | } |
| 894 | |
| 895 | func newConsumerGroupSession(ctx context.Context, parent *consumerGroup, claims map[string][]int32, memberID string, generationID int32, handler ConsumerGroupHandler) (*consumerGroupSession, error) { |
| 896 | // init context |
nothing calls this directly
no outgoing calls
no test coverage detected