nats

Documentation

Index

• type Config
• type Fetch
• type Helper
  • func (h *Helper) AddStream(stream string) error
  • func (h *Helper) Publish(subject string, msg []byte) error
  • func (h *Helper) PullSubscribe(subject string) ([][]byte, error)
  • func (h *Helper) SetJetStreamSubscriber(subject string, durable string)
  • func (h *Helper) SetNatsJetStreamClient()
• type JetStreamClient
• type JetStreamSubscriber
• type Retention

Types

type Config

type Config struct {
	Sockets       []string `validate:"required"`
	IsHeadlessSvc bool
	Stream        string

	Subject  string
	Subjects map[string]string
	Durable  string

	Retention
	Fetch
}

type Fetch

type Fetch struct {
	Interval time.Duration
	Number   int
	Retry    int
}

type Helper

type Helper struct {
	JsClient     JetStreamClient
	JsSubscriber JetStreamSubscriber

	Config
}

func (*Helper) AddStream

func (h *Helper) AddStream(stream string) error

func (*Helper) Publish

func (h *Helper) Publish(subject string, msg []byte) error

func (*Helper) PullSubscribe

func (h *Helper) PullSubscribe(subject string) ([][]byte, error)

func (*Helper) SetJetStreamSubscriber

func (h *Helper) SetJetStreamSubscriber(subject string, durable string)

func (*Helper) SetNatsJetStreamClient

func (h *Helper) SetNatsJetStreamClient()

type JetStreamClient

type JetStreamClient interface {
	StreamInfo(stream string, opts ...nats.JSOpt) (*nats.StreamInfo, error)
	AddStream(*nats.StreamConfig, ...nats.JSOpt) (*nats.StreamInfo, error)
	Publish(string, []byte, ...nats.PubOpt) (*nats.PubAck, error)
	PullSubscribe(string, string, ...nats.SubOpt) (*nats.Subscription, error)
}

type JetStreamSubscriber

type JetStreamSubscriber interface {
	Fetch(batch int, opts ...nats.PullOpt) ([]*nats.Msg, error)
}

type Retention

type Retention struct {
	Second int
	Size   int
}