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
	CleanupPublisher()
		JetStreamContext.CleanupPublisher
	Publish(subj string, data []byte, opts ...PubOpt) (*PubAck, error)
		JetStreamContext.Publish
	PublishAsync(subj string, data []byte, opts ...PubOpt) (PubAckFuture, error)
		JetStreamContext.PublishAsync
	PublishAsyncComplete() <-chan struct{}
		JetStreamContext.PublishAsyncComplete
	PublishAsyncPending() int
		JetStreamContext.PublishAsyncPending
	PublishMsg(m *Msg, opts ...PubOpt) (*PubAck, error)
		JetStreamContext.PublishMsg
	PublishMsgAsync(m *Msg, opts ...PubOpt) (PubAckFuture, error)
		JetStreamContext.PublishMsgAsync
	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
	SubscribeSync(subj string, opts ...SubOpt) (*Subscription, error)
		JetStreamContext.SubscribeSync

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.