A modular implementation of timely dataflow in rust