Module server

An interactive dataflow server.

Structs

CommandReceiver 🔒

Endpoint used by workers to receive compute commands.

ComputeInstanceContext

Caller-provided configuration for compute.

Config 🔒

Configures the server with compute-specific metrics.

NonceChange 🔒

Error type returned on connection nonce changes.

ResponseSender 🔒

Endpoint used by workers to send sending compute responses.

Worker 🔒

State maintained for each worker thread.

Functions

serve

Initiates a timely dataflow computation, processing compute commands.

set_core_affinity 🔒

Set the current thread’s core affinity, based on the given worker_id.

spawn_channel_adapter 🔒

Spawn a thread to bridge between ClusterClient and Worker channels.