amqphandler

Documentation

Index

• type App
  • func New(config Config, mailerApp mailer.App, ...) (App, error)
  • func (a App) Close()
  • func (a App) Done() <-chan struct{}
  • func (a App) Enabled() bool
  • func (a App) Ping() error
  • func (a App) Start(done <-chan struct{})
• type Config
  • func Flags(fs *flag.FlagSet, prefix string) Config

Types

type App

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

App of package

func New

func New(config Config, mailerApp mailer.App, prometheusRegisterer prometheus.Registerer) (App, error)

New creates new App from Config

func (App) Close

func (a App) Close()

Close amqp

func (App) Done

func (a App) Done() <-chan struct{}

Done returns the chan used for synchronization

func (App) Enabled

func (a App) Enabled() bool

Enabled checks if requirements are met

func (App) Ping

func (a App) Ping() error

Ping amqp

func (App) Start

func (a App) Start(done <-chan struct{})

Start amqp handler

type Config

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

Config of package

func Flags

func Flags(fs *flag.FlagSet, prefix string) Config

Flags adds flags for configuring package