outbox

type Config struct {
	// MaxBackoff is the maximum delay between retry attempts.
	// Default: 10 hours
	MaxBackoff time.Duration `mapstructure:"max-backoff"`
}

type Message struct {
	Payload any               // The actual message payload to be sent
	EventID string            // Unique event identifier - used as outbox record ID for idempotency (prevents duplicate messages)
	Key     string            // Kafka partition key for ordering guarantees
	Headers map[string]string // Kafka headers for trace propagation, event_type, etc.
}

type Outbox interface {
	Create(ctx context.Context, msg Message) (SendFunc, error)
}

type SendFunc func(ctx context.Context) error