amqphandler

package
v4.75.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 4, 2024 License: MIT Imports: 17 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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 added in v4.46.3 

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

type Service added in v4.64.0 

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 added in v4.64.0 

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

func (Service) Retry added in v4.64.0 

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

func (*Service) Start added in v4.64.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.