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.
• EpochChange 🔒
  Error type returned on connection epoch 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.