A modular implementation of timely dataflow in Rust - View it on GitHub