| 81 | } |
| 82 | |
| 83 | pubAckFuture struct { |
| 84 | jsClient *jetStreamClient |
| 85 | msg *nats.Msg |
| 86 | retries int |
| 87 | maxRetries int |
| 88 | retryWait time.Duration |
| 89 | ack *PubAck |
| 90 | err error |
| 91 | errCh chan error |
| 92 | doneCh chan *PubAck |
| 93 | reply string |
| 94 | timeout *time.Timer |
| 95 | } |
| 96 | |
| 97 | jetStreamClient struct { |
| 98 | asyncPublishContext |
nothing calls this directly
no outgoing calls
no test coverage detected