amqphandler

Documentation

Index

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

Variables

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

Functions

func GetDeathCount

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

Types

type Config

type Config struct {
	Exchange        string
	Queue           string
	RoutingKey      string
	RetryInterval   time.Duration
	InactiveTimeout time.Duration
	MaxRetry        uint
	Exclusive       bool
}

func Flags

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

type Handler

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

type Service

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

func New

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

func (*Service) Done

func (s *Service) Done() <-chan struct{}

func (*Service) Retry

func (s *Service) Retry(message amqp.Delivery) error

func (*Service) Start

func (s *Service) Start(ctx context.Context)