| 559 | } |
| 560 | |
| 561 | type partitionOffsetManager struct { |
| 562 | parent *offsetManager |
| 563 | topic string |
| 564 | partition int32 |
| 565 | leaderEpoch int32 |
| 566 | |
| 567 | lock sync.Mutex |
| 568 | offset int64 |
| 569 | metadata string |
| 570 | dirty bool |
| 571 | done bool |
| 572 | |
| 573 | releaseOnce sync.Once |
| 574 | errors chan *ConsumerError |
| 575 | } |
| 576 | |
| 577 | func (om *offsetManager) newPartitionOffsetManager(topic string, partition int32) (*partitionOffsetManager, error) { |
| 578 | offset, leaderEpoch, metadata, err := om.fetchInitialOffset(topic, partition, om.conf.Metadata.Retry.Max) |
nothing calls this directly
no outgoing calls
no test coverage detected