commandqueue

type Claim struct {
	ID          string
	Command     EnqueuedCommand
	Attempt     int
	MaxAttempts int
	// contains filtered or unexported fields
}

type EnqueuedCommand struct {
	ID          string // set by queue if empty
	CommandName string
	StreamID    string
	Data        []byte
	Metadata    map[string]string
}

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

type ProcessorConfig struct {
	Queue       Queue
	Handler     func(ctx context.Context, cmd EnqueuedCommand) (*Result, error)
	Concurrency int // max concurrent handlers (default 1 for single-writer)
	Logger      *slog.Logger
}

type Queue interface {
	// Enqueue adds a command to the queue and returns its assigned ID.
	Enqueue(ctx context.Context, cmd EnqueuedCommand) (string, error)
	// EnqueueAndWait enqueues a command and blocks until a result is available or timeout.
	EnqueueAndWait(ctx context.Context, cmd EnqueuedCommand, timeout time.Duration) (*Result, error)
	// Dequeue blocks until a command is available and returns a Claim.
	Dequeue(ctx context.Context) (*Claim, error)
	// Close shuts down the queue, unblocking any waiting Dequeue calls.
	Close() error
}

type Result struct {
	Success       bool
	Error         string
	StreamVersion int
	EventCount    int
	Data          []byte // optional serialized result data
}