stan

Documentation

Index

• Variables
• func NewConsumer(logger zerolog.Logger, stan stan.Conn, subject, qGroup string, maxInFlight int, ...) (*consumer, error)
• func ProduceImageUploadResult(msg *event.ImageUploadResult) 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 ProduceImageUploadResult

func ProduceImageUploadResult(msg *event.ImageUploadResult) error