Pekko CQRS/ES Implementation

Use this skill only when the implementation stack is Scala 3 plus Apache Pekko and the architecture is CQRS/Event Sourcing.

Workflow

1. Confirm the aggregate, commands, events, state lifecycle, and serialization requirements.

2. Keep the domain model separate from the Pekko actor shell.

3. Model command handling as validation plus event emission.

4. Apply events through pure state transition functions.

5. Define Protocol Buffers schemas and evolution rules for persisted events.

6. Put use-case orchestration in ZIO/application services, not inside the aggregate actor.

7. Build read-model updaters as idempotent projections.