nats

Documentation

Index

• type NatsSubscription
  • func NewNatsSubscription(handler *apievent.EventsHandler) *NatsSubscription
  • func (n *NatsSubscription) Close() error
  • func (n *NatsSubscription) Connect(ctx context.Context, connStr string) error

Types

type NatsSubscription

type NatsSubscription struct {
	*event.Router
	// contains filtered or unexported fields
}

NatsSubscription encapsulates the jetstream session providing events.

Extends Router.

func NewNatsSubscription

func NewNatsSubscription(handler *apievent.EventsHandler) *NatsSubscription

NewNatsSubscription creates a new NatsSubscription with the given user store.

func (*NatsSubscription) Close

func (n *NatsSubscription) Close() error

Close cleanly brings down the nats and jetstream connection.

func (*NatsSubscription) Connect

func (n *NatsSubscription) Connect(ctx context.Context, connStr string) error

Connect sets up the connection to the nats server and a consumer for the "Jetstream".

Fails if connection fails or the "Jetstream" consumer cannot be set up.

Once connected, it will attempt to reconnect if disconnected.