[feat] eGo projection

[Tochemey]

Add a better projection engine to consume events persisted in the journal to build a read model

[pablogore]

I was working to add a middleware, polling database (could be an actor or a cron) looking for the new events and adding the events to the Kafka / nats topic.
After that, we can subscribe to that topic, read the events and store them in a read model table

[Tochemey]

Hello @pablogore
Thanks for the comment. We can pair on this and discuss the approach if you want. You can also open a PR to implement it.

I have been considering doing this #33 first and then implement the projection. I implemented it sometimes using a db polling mechanism but I abandoned it because I was suspecting some performance issue. The old code base is somewhere d3cd4e3

[Tochemey]

@pablogore The main reason I abandoned the old implementation is that I am planning to read the data per partition when running in a cluster.

[Tochemey]

@pablogore I have added the projection implementation. I will be adding a mechanism to run it in a singleton manner in a cluster.