nats

Documentation

Overview

Package nats is a module for nats

Index

• type NatsContext
  • func NewNats(opts ...Option) (NatsContext, error)
• type NatsOptions
• type Option
  • func WithNatsURL(url string) Option

Types

type NatsContext

type NatsContext interface {
	// GetConn returns the nats connection
	GetConn() *nats.Conn

	// GetJetStreamContext returns the nats jetstream context
	GetJetStreamContext() nats.JetStreamContext

	// CreateStream creates a new stream
	CreateStream(streamName string, subject string) error

	// Subscribe subscribes to a stream
	Subscribe(subject string, handler func(msg *nats.Msg) error) error
}

func NewNats

func NewNats(opts ...Option) (NatsContext, error)

NewNats creates a new nats connection

type NatsOptions

type NatsOptions struct {
	URL string
}

NatsOptions defines the NATS configuration

type Option

type Option func(*NatsOptions)

Option is the func interface to assign options

func WithNatsURL

func WithNatsURL(url string) Option

WithNatsURL defines the NATS URL