outbox

type Config struct {
	PollInterval time.Duration
	BatchSize    int
}

type Message struct {
	ID          string
	Topic       string
	Key         string
	Payload     []byte
	Headers     map[string]string
	Status      MessageStatus
	Retries     int
	LastError   string
	CreatedAt   time.Time
	ProcessedAt time.Time
}

type MessageStatus string

type Option interface {
	Apply(*Config)
}

type OptionFunc func(*Config)

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

type Publisher interface {
	Publish(ctx context.Context, msgs ...Message) error
}

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

type Store interface {
	// Save persists messages within the given transaction.
	// tx can be pgx.Tx, *sql.Tx, or nil (Store creates its own transaction).
	Save(ctx context.Context, tx any, msgs ...Message) error

	// FetchPending atomically claims up to limit pending messages for processing.
	FetchPending(ctx context.Context, limit int) ([]Message, error)

	// MarkProcessed marks messages as successfully processed.
	MarkProcessed(ctx context.Context, ids ...string) error

	// MarkFailed increments retries and records the error.
	// Sets status to failed when max retries reached, else back to pending.
	MarkFailed(ctx context.Context, id string, err error) error
}