cmq

Documentation

Index

• Constants
• type CMQ
  • func New(cfg Config, logger *zap.Logger) (*CMQ, error)
  • func (c *CMQ) Streams() error
• type Config

Constants

const (
	EventsChannel = "events"
	QueueName     = "saf"
	DurableName   = "saf"
)

Types

type CMQ

type CMQ struct {
	Conn   *nats.Conn
	JConn  nats.JetStreamContext
	Logger *zap.Logger
}

func New

func New(cfg Config, logger *zap.Logger) (*CMQ, error)

func (*CMQ) Streams

func (c *CMQ) Streams() error

type Config

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