Module server 

An interactive dataflow server.

Structs

Config 🔒

Configures a dataflow server.

Constants

STORAGE_ID_OFFSET 🔒

Offset added to storage operator/channel IDs to avoid collisions with compute IDs.

Functions

remap_timely_event_ids 🔒

Remaps operator, channel, and address IDs in a TimelyEvent so that events forwarded to compute’s logging dataflow don’t collide with compute’s IDs.

serve

Initiates a timely dataflow computation, processing storage commands.

Type Aliases

TimelyLogWriter 🔒

Per-worker writer handle for forwarding timely logging events to compute.