amqphandler

Documentation

Index

• Variables
• func GetDeathCount(message amqp.Delivery) (int64, error)
• type App
  • func New(config Config, amqpClient *amqpclient.Client, ...) (*App, error)
  • func (a *App) Done() <-chan struct{}
  • func (a App) Retry(message amqp.Delivery) error
  • func (a *App) Start(ctx context.Context)
• type Config
  • func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config
• type Handler

Variables

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

Functions

func GetDeathCount

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

Types

type App

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

func New

func New(config Config, amqpClient *amqpclient.Client, metricProvider metric.MeterProvider, tracerProvider trace.TracerProvider, handler Handler) (*App, error)

func (*App) Done

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

func (App) Retry

func (a App) Retry(message amqp.Delivery) error

func (*App) Start

func (a *App) Start(ctx context.Context)

type Config

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

func Flags

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

type Handler

type Handler func(context.Context, amqp.Delivery) error