openmeter
openmeter copied to clipboard
RFC: split StreamingConnector into ingestion and aggregation component
Currently ingestion and aggregation are tightly coupled together. I believe they should be two separate domains, even though the components of the underlying technology are tightly coupled as well.
By separating these modules it becomes easier to reason about the system as each component (ingestion, aggregation) will be responsible for their part only. It also becomes easier to cover the system with tests.
Ingestion component has been moved out to its own module. Aggregation needs some more refactors.
@hekike can you share your architectural diagram here?
I think we are close to getting this done.