Command base dataclass

Auto-generated command_id

Auto-generated timestamp

CommandHandler ABC Generic

CommandBus register/dispatch

CommandBus ValueError

QueryHandler ABC Generic

QueryBus register/dispatch

QueryBus ValueError

Async handlers

Separate command and query models

Validation in command handler

No reads in command handlers

Denormalized view records

Projection handles() method

Projection apply() is async

Projection clear() method

Per-projection checkpoints

Sync reads from checkpoint

Checkpoint updated after events

run() uses asyncio.sleep loop

rebuild_projection clears first

rebuild_projection resets checkpoint

rebuild_projection replays all

Event types have global_position

POST for create command

PUT for update command

GET for single query

GET for list query

CommandBus via Depends

QueryBus via Depends

PaginatedResult items field

PaginatedResult total field

PaginatedResult page fields

PaginatedResult total_pages

Consistency handler timeout

Stale data warning

Buses stored on app.state

event_store.append_events called

stream_id naming convention

stream_type parameter

uncommitted_events used

Aggregate factory method

Validation before persist

Command dataclass with auto-fields

Async append_events

No query in command handler

Event versioning

Separate write/read models

sort_by default 'created_at'

sort_order default 'desc'

Optional filter appended conditionally

page_size default 20

Query handler reads from read_db only

No state mutation in query handler

QueryHandler ABC Generic pattern

PaginatedResult structure

total_pages ceiling division

QueryBus dispatch by type

Query base dataclass

DELETE verb for removal

POST for create command

GET for query endpoints

CommandBus via Depends

QueryBus via Depends

Buses stored on app.state

Event version field

Independent write model

Independent read view model

No query in command handler

404 on not found query