Expand description
An interactive dataflow server.
Structs§
- Endpoint used by workers to receive compute commands.
- Caller-provided configuration for compute.
- Configures the server with compute-specific metrics.
- Endpoint used by workers to send sending compute responses.
- Worker 🔒State maintained for each worker thread.
Functions§
- Initiates a timely dataflow computation, processing compute commands.
- Set the current thread’s core affinity, based on the given
worker_id
.