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.

Enums

ComputeRuntimeRole

Which of a process’s compute runtimes a given runtime is.

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 task to bridge between ClusterClient and Worker channels.

Type Aliases

StorageTimelyLogReader 🔒

Type alias for the storage timely log reader.