Event Sourcing - repository
| class MyRepository: | |
| def get(self, id_) -> MyAggregate: | |
| """Replay an aggregate from the event log.""" | |
| ... | |
| def persist(self, aggregate: MyAggregate) -> None: | |
| self._insert_new_events(aggregate.pop_pending_events()) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment