amqphandler

Documentation

Index

• Variables
• func GetDeathCount(message amqp.Delivery) (int64, error)
• type App
  • func New(config Config, amqpClient *amqpclient.Client, ...) (App, error)
  • func NewFromString(amqpClient *amqpclient.Client, handler func(amqp.Delivery) error, ...) (App, error)
  • func (a App) Done() <-chan struct{}
  • func (a App) Enabled() bool
  • func (a App) Retry(log logger.Provider, message amqp.Delivery) error
  • func (a App) Start(done <-chan struct{})
• type Config
  • func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config

Variables

var ErrNoDeathCount = errors.New("no death count")

ErrNoDeathCount occurs when no death count is found in message

Functions

func GetDeathCount

func GetDeathCount(message amqp.Delivery) (int64, error)

GetDeathCount of a message

Types

type App

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

App of package

func New

func New(config Config, amqpClient *amqpclient.Client, handler func(amqp.Delivery) error) (App, error)

New creates new App from Config

func NewFromString

func NewFromString(amqpClient *amqpclient.Client, handler func(amqp.Delivery) error, exchange, queue, routingKey, retryInterval string, maxRetry uint) (App, error)

NewFromString creates new App from string configuration

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) Retry

func (a App) Retry(log logger.Provider, message amqp.Delivery) error

Retry a message if possible on error

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, overrides ...flags.Override) Config

Flags adds flags for configuring package