EventsPoll

This library distributes new events to specific channels as per their EventAction type, in a fan-out approach.

How it works:

• Listen for new events on specified topic.
• Filter events and only process ones for the specified Aggregate.
• Get the Max Aggregate-Version from Database.
• Send request to EventStoreQuery with the Max Aggregate-Version.
• Get events from EventStoreQuery.
• Fan-Out events to their respective channels based on Event.EventAction.

How to use

• Check examples for how to use this library.
• Check tests-file for additional examples.

• Go Docs