[otap-dataflow] pipeline engine timer control #497
Labels
enhancement
New feature or request
pipeline
Rust Pipeline Related Tasks
rust
Pull requests that update Rust code
Uh oh!
There was an error while loading. Please reload this page.
There's a control message called
TimerTick
. The intention here is for components of the pipeline to register a new timer with the pipeline engine, and the engine will periodically send aTimerTick
control message into this component.See the implementation in experimental beaubourg for inspiration:
https://github.com/open-telemetry/otel-arrow/blob/main/rust/beaubourg/crates/signal/src/lib.rs
Prerequisite:
The text was updated successfully, but these errors were encountered: