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.

StorageConn 🔒

A storage client connection.

StorageGuest 🔒

Per-worker state for hosting storage objects on the compute cluster.

StorageGuestConfig

Configuration for hosting storage objects on the compute cluster.

Worker 🔒

State maintained for each worker thread.

Enums

ComputeRuntimeRole

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

WorkerCommand 🔒

A command dispatched to the worker from the command channel.

Functions

serve

Initiates a timely dataflow computation, processing compute commands.

serve_inner 🔒

Builds the Timely cluster for the given config and returns its worker threads along with a builder for compute clients to it.

serve_unified

Initiates a timely dataflow computation that processes compute commands and additionally hosts storage objects, processing storage commands received over a separate client connection.

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

StorageClientRx 🔒

A per-worker channel delivering storage client connections.