| 382 | } |
| 383 | |
| 384 | type testFuncConsumerGroupMember struct { |
| 385 | ConsumerGroup |
| 386 | t *testing.T |
| 387 | clientID string |
| 388 | isCapped bool |
| 389 | sink *testFuncConsumerGroupSink |
| 390 | |
| 391 | generationId atomic.Int32 |
| 392 | state atomic.Int32 |
| 393 | handlers atomic.Int32 |
| 394 | maxMessages atomic.Int32 |
| 395 | |
| 396 | mu sync.RWMutex |
| 397 | claims map[string]int |
| 398 | errs []error |
| 399 | } |
| 400 | |
| 401 | func defaultConfig(clientID string) *Config { |
| 402 | config := NewFunctionalTestConfig() |
nothing calls this directly
no outgoing calls
no test coverage detected