Event dataclass

stream_id field

global_position field

version field

Projection ABC

Abstract name property

Abstract handles method

Abstract apply method

asyncpg Pool usage

Pool acquire pattern

Handler dispatch dict

Denormalized table

Three event types handled

Separate handler methods

Projector constructor

Projections list

Register method

Polling interval

Default batch size 100

Rebuild batch size 1000

Checkpoint default to 0

Checkpoint save per event

Saves global_position

Rebuild deletes checkpoint

Rebuild uses projection name

Handles unregistered types

ON CONFLICT upsert

Incremental counter update

Transaction for multi-table

Both tables in transaction

asyncpg Pool pattern

Idempotent daily upsert

Handler dispatch dict

Error handling present

Date extraction for daily key

Separate projection classes

Implementation notes file

AsyncElasticsearch import

AsyncElasticsearch constructor param

Index attribute

Projection ABC inheritance

handles() returns product events

es.index() for creation

es.update() for ProductUpdated

es.update() for price change

es.delete() for removal

Async apply method

design_notes mentions client

design_notes maps operations

Three separate classes

No cross-projection references

Projection ABC inheritance

asyncpg Pool pattern

Denormalized user profile

ON CONFLICT upsert for daily metrics

Date slice for daily key

Incremental counter in upsert

Support ticket schema

Handler dispatch dict

architecture_notes mentions independence

architecture_notes mentions denormalization

Projector constructor args

Polling interval 0.1s

Lag calculation present

Lag warning logged

Configurable lag threshold

Exception catch in run loop

Error log with context

Checkpoint default to 0

Checkpoint save per event

global_position for checkpoint

observability_notes covers ordering

observability_notes covers lag detection