relay

type Config struct {
	Owner                string
	BatchSize            int
	Workers              int
	LeaseDuration        time.Duration
	LeaseRenewalInterval time.Duration
	MaxAttempts          int
	PollInterval         time.Duration
	TransitionTimeout    time.Duration
	Clock                func() time.Time
	Backoff              func(attempt int) time.Duration
	ClassifyError        func(error) ErrorClass
	Wait                 func(context.Context, time.Duration) error
	Serialization        postgres.SerializationMode
	Observer             outbox.Observer
	Logger               *slog.Logger
	Heartbeat            func(context.Context, time.Duration, func(context.Context) error) error
}

type ErrorClass uint8

type Publisher interface {
	Publish(context.Context, outbox.Envelope) error
}

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

type Result struct {
	Claimed      int
	Published    int
	Delivered    int
	Retried      int
	DeadLettered int
	Released     int
}

type Store interface {
	Ping(context.Context) error
	Claim(context.Context, postgres.ClaimRequest) ([]postgres.Claim, error)
	ExtendLease(context.Context, postgres.LeaseRef, time.Duration) (time.Time, error)
	MarkDelivered(context.Context, postgres.LeaseRef) error
	Retry(context.Context, postgres.LeaseRef, time.Time, error) error
	DeadLetter(context.Context, postgres.LeaseRef, error) error
	ReleaseLease(context.Context, postgres.LeaseRef) error
}