nats

Documentation

Index

• type Broker
  • func New(cfg Options, lo logf.Logger) (*Broker, error)
  • func (b *Broker) Consume(ctx context.Context, work chan []byte, queue string)
  • func (b *Broker) Enqueue(_ context.Context, msg []byte, queue string) error
• type Options

Types

type Broker

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

Broker is a nats-jetstream based broker implementation.

func New

func New(cfg Options, lo logf.Logger) (*Broker, error)

New() returns a new instance of nats-jetstream broker.

func (*Broker) Consume

func (b *Broker) Consume(ctx context.Context, work chan []byte, queue string)

func (*Broker) Enqueue

func (b *Broker) Enqueue(_ context.Context, msg []byte, queue string) error

type Options

type Options struct {
	URL         string `yaml:"url"`
	EnabledAuth bool   `yaml:"enabled_auth"`
	Username    string `yaml:"username"`
	Password    string `yaml:"password"`

	// Stream -> Subjects map
	Streams map[string][]string `yaml:"streams"`
}