natsio

Documentation

Index

• Constants
• func Connect(name string) (*nats.Conn, error)
• type Nats
  • func New(conn *nats.Conn, l zerolog.Logger, cfg *config.Conf, db *mongo.Database) *Nats
  • func (n *Nats) InitSubscribers() error
• type ScanError

Constants

const (
	ScanQueue        = "scans"
	ScanStartSubj    = "scan.start"
	ScanCompleteSubj = "scan.complete"
	ScanRetrySubj    = "scan.retry"
	ScanFailSubj     = "scan.fail"
)

Functions

func Connect

func Connect(name string) (*nats.Conn, error)

Types

type Nats

type Nats struct {
	Conn *nats.Conn

	L  zerolog.Logger
	C  *config.Conf
	DB *mongo.Database
}

func New

func New(conn *nats.Conn, l zerolog.Logger, cfg *config.Conf, db *mongo.Database) *Nats

func (*Nats) InitSubscribers

func (n *Nats) InitSubscribers() error

type ScanError

type ScanError struct {
	Message string   `json:"message,omitempty"`
	Scan    api.Scan `json:"scan"`
}