retry

type DLQEntry struct {
	OriginalMessageID string         `json:"original_message_id"`
	CorrelationID     string         `json:"correlation_id"`
	ChannelID         string         `json:"channel_id"`
	OriginalPayload   string         `json:"original_payload,omitempty"`
	Error             string         `json:"error"`
	Destination       string         `json:"destination"`
	Timestamp         time.Time      `json:"timestamp"`
	Metadata          map[string]any `json:"metadata,omitempty"`
}

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

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

type QueueFullError struct {
	Name string
}

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

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

type SendFunc func(ctx context.Context, msg *message.Message) (*message.Response, error)