nats

Documentation

Index

• type Nats
  • func NewNats(clusterName string, opts ...stan.Option) (*Nats, error)
  • func (n *Nats) Publish(ctx context.Context, topic string, m *pubsub.Msg) error
  • func (n *Nats) Shutdown()
  • func (n *Nats) Subscribe(opts pubsub.HandlerOptions, h pubsub.MsgHandler)

Types

type Nats

type Nats struct {
	// contains filtered or unexported fields
}

Nats provides nats publish and subscribe

func NewNats

func NewNats(clusterName string, opts ...stan.Option) (*Nats, error)

NewNats creates a new Nats connection for a project

func (*Nats) Publish

func (n *Nats) Publish(ctx context.Context, topic string, m *pubsub.Msg) error

Publish implements Publish

func (*Nats) Shutdown

func (n *Nats) Shutdown()

Shutdown shuts down all subscribers gracefully

func (*Nats) Subscribe

func (n *Nats) Subscribe(opts pubsub.HandlerOptions, h pubsub.MsgHandler)

Subscribe implements Subscribe for Nats