retry

Documentation

Index

• Variables
• type MessagePublisher
• type NoOpMessagePublisher
  • func (nop *NoOpMessagePublisher) Close()
  • func (nop *NoOpMessagePublisher) ProduceRaw(ctx context.Context, key interface{}, msg *amqp.Publishing) error
• type RetryPublisher
  • func NewRetryPublisherConfig(options ...RetryPublisherConfigOption) *RetryPublisher
  • func (r *RetryPublisher) OnError(ctx context.Context, raw *amqp.Delivery) error
• type RetryPublisherConfigOption
  • func WithMessagePublisher(publisher MessagePublisher) RetryPublisherConfigOption

Variables

var (
	ErrFailedToProduceRetryMessage = errors.New("failed to produce retry message")
	ErrFailedToAckMessage          = errors.New("failed to ack message")
)

Types

type MessagePublisher

type MessagePublisher interface {
	ProduceRaw(ctx context.Context, key interface{}, msg *amqp.Publishing) error
	Close()
}

type NoOpMessagePublisher

type NoOpMessagePublisher struct{}

func (*NoOpMessagePublisher) Close

func (nop *NoOpMessagePublisher) Close()

func (*NoOpMessagePublisher) ProduceRaw

func (nop *NoOpMessagePublisher) ProduceRaw(ctx context.Context, key interface{}, msg *amqp.Publishing) error

type RetryPublisher

type RetryPublisher struct {
	MessagePublisher MessagePublisher
}

func NewRetryPublisherConfig

func NewRetryPublisherConfig(options ...RetryPublisherConfigOption) *RetryPublisher

func (*RetryPublisher) OnError

func (r *RetryPublisher) OnError(ctx context.Context, raw *amqp.Delivery) error

type RetryPublisherConfigOption

type RetryPublisherConfigOption func(*RetryPublisher)

func WithMessagePublisher

func WithMessagePublisher(publisher MessagePublisher) RetryPublisherConfigOption