| 131 | ConsumeErrHandlerFunc func(consumeCtx ConsumeContext, err error) |
| 132 | |
| 133 | pullSubscription struct { |
| 134 | sync.Mutex |
| 135 | id string |
| 136 | consumer *pullConsumer |
| 137 | subscription *nats.Subscription |
| 138 | msgs chan *nats.Msg |
| 139 | msgsClosed atomic.Uint32 |
| 140 | errs chan error |
| 141 | pending pendingMsgs |
| 142 | hbMonitor *hbMonitor |
| 143 | fetchInProgress atomic.Uint32 |
| 144 | closed atomic.Uint32 |
| 145 | draining atomic.Uint32 |
| 146 | done chan struct{} |
| 147 | connStatusChanged chan nats.Status |
| 148 | fetchNext chan *pullRequest |
| 149 | consumeOpts *consumeOpts |
| 150 | delivered int |
| 151 | closedCh chan struct{} |
| 152 | } |
| 153 | |
| 154 | pendingMsgs struct { |
| 155 | msgCount int |
nothing calls this directly
no outgoing calls
no test coverage detected