outbox

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

type Message struct {
	Event   events.Event      // Event payload - must implement events.Event interface
	Key     string            // Kafka partition key for ordering guarantees
	Headers map[string]string // Kafka headers for trace propagation, etc.
}

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

type SendFunc func(ctx context.Context) error