nats

Documentation

Index

• type Broker
  • func New(cfg Options, lo *slog.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
  • func (b *Broker) EnqueueScheduled(ctx context.Context, msg []byte, queue string, ts time.Time) error
  • func (b *Broker) GetPending(ctx context.Context, queue string) ([]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 *slog.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

func (*Broker) EnqueueScheduled

func (b *Broker) EnqueueScheduled(ctx context.Context, msg []byte, queue string, ts time.Time) error

func (*Broker) GetPending

func (b *Broker) GetPending(ctx context.Context, queue string) ([]string, error)

type Options

type Options struct {
	URL         string
	EnabledAuth bool
	Username    string
	Password    string

	// Stream -> Subjects map
	Streams map[string][]string
}