messaging

Documentation

Index

• func Init()
• func SetNewPDF(fn func(options *pdfUtil.Options) pdfUtil.PDFer)
• func SetupConsumer(conn messageUtil.Connection, publisher *Publisher, ...) error
• type Publisher
  • func SetupPublisher(conn messageUtil.Connection) (*Publisher, error)
  • func (p *Publisher) Publish(routeKey string, message *messages.PDFGenerateResponse) error

Functions

func Init

func Init()

func SetNewPDF

func SetNewPDF(fn func(options *pdfUtil.Options) pdfUtil.PDFer)

func SetupConsumer

func SetupConsumer(conn messageUtil.Connection, publisher *Publisher, fileStore filestorage.FileStorager, db database.Database) error

Types

type Publisher

type Publisher struct {
	// contains filtered or unexported fields
}

func SetupPublisher

func SetupPublisher(conn messageUtil.Connection) (*Publisher, error)

func (*Publisher) Publish

func (p *Publisher) Publish(routeKey string, message *messages.PDFGenerateResponse) error