MCPcopy
hub / github.com/nats-io/nats.go / pubAckFuture

Struct pubAckFuture

jetstream/publish.go:83–95  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected