mirror of
https://github.com/siderolabs/talos.git
synced 2025-10-25 14:31:11 +02:00
fb585902a3
The idea here is to use single slice of events for all the consumers. Each consumer keeps its own position within the stream, and stream is structured as circular buffer to avoid using too much memory. This implementation allows for one more future: looking "back" into the event history and returning past event starting with some offset (e.g. timestamp, event ID, etc.). This feature is not implemented yet. Signed-off-by: Andrey Smirnov <smirnov.andrey@gmail.com>