retry

package

v1.9.0 Latest Latest Go to latest Published: Aug 18, 2025 License: MIT Imports: 6 Imported by: 1

Details

View Source

const (
	Forever = -1
)

This section is empty.

This section is empty.

type Policy struct {
	Retries          []Retry
	FinallyMoveToDlq bool
}

func NewPolicy(finallyMoveToDlq bool, retries ...Retry) Policy

type Publisher interface {
	PublishWithConfirmation(ctx context.Context, exchange string, routingKey string, msg *amqp.Publishing) error
}

type Retry struct {
	Delay       time.Duration
	MaxAttempts int
}

func ForeverWithDelay(delay time.Duration) Retry

func WithDelay(delay time.Duration, maxTries int) Retry

func (r Retry) QueueName(originalQueue string) string

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

func NewRetryer(originalQueue string, policy Policy, pub Publisher) *Retryer

func (r *Retryer) Do(delivery *amqp.Delivery) error