stan

Documentation

Index

• Variables
• func NewConsumer(logger zerolog.Logger, stan stan.Conn, subject, qGroup string, maxInFlight int, ...) (*consumer, error)
• func ProduceCompanyNew(msg *event.CompanyNew) error
• func ProduceDeleteImage(msg *event.DeleteImage) error

Variables

var Conn s.Conn

Functions

func NewConsumer

func NewConsumer(logger zerolog.Logger, stan stan.Conn, subject, qGroup string, maxInFlight int, cb cb) (*consumer, error)

func ProduceCompanyNew

func ProduceCompanyNew(msg *event.CompanyNew) error

func ProduceDeleteImage

func ProduceDeleteImage(msg *event.DeleteImage) error