type github.com/nats-io/nats.go.JetStream (interface)
Method Implmentations
ChanQueueSubscribe(subj, queue string, ch chan *Msg, opts ...SubOpt) (*Subscription, error)
JetStreamContext.ChanQueueSubscribe
ChanSubscribe(subj string, ch chan *Msg, opts ...SubOpt) (*Subscription, error)
JetStreamContext.ChanSubscribe
PublishAsync(subj string, data []byte, opts ...PubOpt) (PubAckFuture, error)
JetStreamContext.PublishAsync
PullSubscribe(subj, durable string, opts ...SubOpt) (*Subscription, error)
JetStreamContext.PullSubscribe
QueueSubscribe(subj, queue string, cb MsgHandler, opts ...SubOpt) (*Subscription, error)
JetStreamContext.QueueSubscribe
QueueSubscribeSync(subj, queue string, opts ...SubOpt) (*Subscription, error)
JetStreamContext.QueueSubscribeSync
Subscribe(subj string, cb MsgHandler, opts ...SubOpt) (*Subscription, error)
JetStreamContext.Subscribe
![]() |
The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds. |