primus.command_worker.repository module

Provider-neutral in-memory reference semantics for command repositories.

class primus.command_worker.repository.InMemoryCommandRepository

Bases: object

Thread-safe executable reference for the CommandRepository contract.

__init__() → None

announce(command: CommandRecord) → AnnouncementResult

discoverable_dispatches() → tuple[CommandEnvelope, ...]

get(tenant_id: str, command_id: str) → CommandRecord | None

request_cancel(tenant_id: str, command_id: str, now: datetime) → CancellationResult | None

set_status(tenant_id: str, command_id: str, status: CommandStatus) → CommandRecord

Advance status in reference integration tests and future adapter tests.