nats

Documentation

Index

• Constants
• type Config
• type Nats
  • func NewConnection(cfg Config, logger *zap.Logger) (*Nats, error)
  • func (n *Nats) CreateStream() error

Constants

const (
	ChannelName = "EVENTS"
	SubjectName = "EVENTS.*"
)

Types

type Config

type Config struct {
	URL string `koanf:"url"`
}

type Nats

type Nats struct {
	Connection *nats.Conn
	JSCtx      nats.JetStreamContext
	Logger     *zap.Logger
}

func NewConnection

func NewConnection(cfg Config, logger *zap.Logger) (*Nats, error)

func (*Nats) CreateStream

func (n *Nats) CreateStream() error