nats

Documentation

Index

• type Nats
  • func NewNats(client *nats.Conn) *Nats
  • func (n *Nats) AsyncSubscribe(ctx context.Context, topic, consumer string, handler providers.MessageHandler) error
  • func (n *Nats) Publish(ctx context.Context, topic string, message map[string]any) error
  • func (n *Nats) Subscribe(ctx context.Context, topic, consumer string, handler providers.MessageHandler) error

Types

type Nats

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

Nats is a struct for a nats stream provider

func NewNats

func NewNats(client *nats.Conn) *Nats

NewNats returns a new nats stream provider

func (*Nats) AsyncSubscribe

func (n *Nats) AsyncSubscribe(ctx context.Context, topic, consumer string, handler providers.MessageHandler) error

AsyncSubscribe subscribes to a topic and calls the handler in a goroutine

func (*Nats) Publish

func (n *Nats) Publish(ctx context.Context, topic string, message map[string]any) error

Publish publishes a message to a topic

func (*Nats) Subscribe

func (n *Nats) Subscribe(ctx context.Context, topic, consumer string, handler providers.MessageHandler) error

Subscribe subscribes to a topic