search

kmgreen2 / agglo

Agglo: A Process-Anywhere Framework for Event Stream Processing
https://kmgreen2.github.io/agglo/
MIT License
2 stars 0 forks source link

StreamStore and Ticker Needs to Store State Externally #13

Closed kmgreen2 closed 3 years ago

kmgreen2 commented 3 years ago

The main state is a head for each substream, a head for the ticker and a distributed lock for each substream and ticker.

We can just use the underlying KVStore for this stuff. Just need to make sure there are no naming conflicts.