| 28 | |
| 29 | type ( |
| 30 | orderedConsumer struct { |
| 31 | js *jetStream |
| 32 | cfg *OrderedConsumerConfig |
| 33 | stream string |
| 34 | currentConsumer *pullConsumer |
| 35 | currentSub *pullSubscription |
| 36 | cursor cursor |
| 37 | namePrefix string |
| 38 | serial int |
| 39 | consumerType consumerType |
| 40 | doReset chan struct{} |
| 41 | resetInProgress atomic.Uint32 |
| 42 | userErrHandler ConsumeErrHandler |
| 43 | stopAfter int |
| 44 | stopAfterMsgsLeft chan int |
| 45 | withStopAfter bool |
| 46 | runningFetch *fetchResult |
| 47 | subscription *orderedSubscription |
| 48 | sync.Mutex |
| 49 | } |
| 50 | |
| 51 | orderedSubscription struct { |
| 52 | consumer *orderedConsumer |
nothing calls this directly
no outgoing calls
no test coverage detected