cmq

Documentation

Index

• type CMQ
  • func New(cfg Config, logger *zap.Logger) (*CMQ, error)
  • func (c *CMQ) Stream(sc *nats.StreamConfig) error
• type Config

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)

New creates a new connection to nats cluster with jetstream support.

func (*CMQ) Stream

func (c *CMQ) Stream(sc *nats.StreamConfig) error

type Config

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