Module mz_compute::server

An interactive dataflow server.

Structs

• CommandReceiver 🔒
  Endpoint used by workers to receive compute commands.
• CommandReceiverQueue 🔒
• ComputeInstanceContext
  Caller-provided configuration for compute.
• Config
  Configures the server with compute-specific metrics.
• 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.

Type Aliases

• ActivatorSender 🔒