consumer

Documentation

Index

• Variables
• type Closer
• type Consumer
  • func New(handler Handler, queue string, opts ...Option) Consumer
  • func (c *Consumer) Handler() Handler
• type Delivery
  • func NewDelivery(donner Donner, source *amqp.Delivery, retrier *retry.Retryer) *Delivery
  • func (d *Delivery) Ack() error
  • func (d *Delivery) Nack(requeue bool) error
  • func (d *Delivery) Retry() error
  • func (d *Delivery) Source() *amqp.Delivery
• type Donner
• type Handler
• type HandlerFunc
  • func (f HandlerFunc) Handle(ctx context.Context, delivery *Delivery)
• type Middleware
• type Option
  • func WithCloser(closer Closer) Option
  • func WithConcurrency(concurrency int) Option
  • func WithMiddlewares(middlewares ...Middleware) Option
  • func WithName(name string) Option
  • func WithPrefetchCount(prefetchCount int) Option
  • func WithRetryPolicy(policy retry.Policy) Option

Variables

var (
	ErrDeliveryAlreadyHandled = errors.New("delivery already handled")
)

Types

type Closer

type Closer interface {
	Close()
}

type Consumer

type Consumer struct {
	Queue         string
	Name          string
	Concurrency   int
	PrefetchCount int
	Middlewares   []Middleware
	RetryPolicy   *retry.Policy
	Closer        Closer
	// contains filtered or unexported fields
}

func New

func New(handler Handler, queue string, opts ...Option) Consumer

func (*Consumer) Handler

func (c *Consumer) Handler() Handler

type Delivery

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

func NewDelivery

func NewDelivery(donner Donner, source *amqp.Delivery, retrier *retry.Retryer) *Delivery

func (*Delivery) Ack

func (d *Delivery) Ack() error

func (*Delivery) Nack

func (d *Delivery) Nack(requeue bool) error

func (*Delivery) Retry

func (d *Delivery) Retry() error

func (*Delivery) Source

func (d *Delivery) Source() *amqp.Delivery

type Donner

type Donner interface {
	Done()
}

type Handler

type Handler interface {
	Handle(ctx context.Context, delivery *Delivery)
}

type HandlerFunc

type HandlerFunc func(ctx context.Context, delivery *Delivery)

func (HandlerFunc) Handle

func (f HandlerFunc) Handle(ctx context.Context, delivery *Delivery)

type Middleware

type Middleware func(next Handler) Handler

type Option

type Option func(c *Consumer)

func WithCloser

func WithCloser(closer Closer) Option

func WithConcurrency

func WithConcurrency(concurrency int) Option

func WithMiddlewares

func WithMiddlewares(middlewares ...Middleware) Option

func WithName

func WithName(name string) Option

func WithPrefetchCount

func WithPrefetchCount(prefetchCount int) Option

func WithRetryPolicy

func WithRetryPolicy(policy retry.Policy) Option