plafer / Tissue.jl

Framework for building computational graphs that process any real time data source.
https://plafer.github.io/Tissue.jl/stable/
MIT License
2 stars 1 forks source link

Flow limiter: add closed loop control #6

Open plafer opened 3 years ago

plafer commented 3 years ago

The current flow limiter is currently an open loop controller. Based on how fast calculators a running, we pull new packet from the source calculator. We should "close the loop" by actually monitoring the channels in the graph to make sure they're not overflowing. This could technically happen, for example if there are sudden changes in how fast a certain calculator runs (e.g. the network drops and the calculator is waiting for the connection to come back up).