jetstream

Documentation

Index

• type Client
  • func New(conf *config.NATS, monitor monitor.Monitor) (*Client, error)
• type JSClient
• type NatsClient

Types

type Client

type Client struct {
	Context JSClient
	Server  NatsClient
}

func New

func New(conf *config.NATS, monitor monitor.Monitor) (*Client, error)

Create new jetstream client.

type JSClient

type JSClient interface {
	Subscribe(subj string, cb nats.MsgHandler, opts ...nats.SubOpt) (*nats.Subscription, error)
	QueueSubscribe(subj, queue string, cb nats.MsgHandler, opts ...nats.SubOpt) (*nats.Subscription, error)
	Publish(subj string, data []byte, opts ...nats.PubOpt) (*nats.PubAck, error)
	// PublishMsg publishes a Msg to JetStream.
	PublishMsg(m *nats.Msg, opts ...nats.PubOpt) (*nats.PubAck, error)
	// AddStream creates a stream.
	AddStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error)
	// DeleteStream deletes a stream.
	DeleteStream(name string, opts ...nats.JSOpt) error
}

type NatsClient

type NatsClient interface {
	Close()
}