Event-sourcing con akka-persistance: stato crescente come lista?

Question

Sto progettando un backend usando CQRS + Event sourcing, usando Akka + Scala. Non sono sicuro di come gestire uno stato crescente. Ad esempio, avrò un elenco crescente di utenti. A mio avviso, ogni utente verrà creato in seguito a un evento UserCreated, tali eventi verranno riprodotti da PersistentActor e gli utenti verranno archiviati in una raccolta. Qualcosa di simile:

class UsersActor extends PersistentActor { 

    override def persistenceId = .... 

    private case class UsersState(users: List[User]) 

    private var state = UsersState() 

    .... 
} 

Ovviamente tale stato sarebbe poi crescere troppo grande per essere tenuto in memoria per questo attore, quindi credo che sto facendo qualcosa di sbagliato.

Ho trovato il progetto di esempio this: l'idea sembra che ogni utente debba essere tenuto da un diverso attore e caricato (dalla cronologia eventi) secondo necessità.

Qual è il modo giusto per farlo? Molte grazie.

Answer 1

La risposta è: ogni aggregato/entità (nel mio esempio, ciascun utente) ottiene il proprio attore, che incorpora lo stato per quella particolare entità e quella solo.