Crate coord[][src]

Coordinates client requests with the dataflow layer.

This crate hosts the "coordinator", an object which sits at the center of the system and coordinates communication between the various components. Responsibilities of the coordinator include:

The main interface to the coordinator is Client. To start a coordinator, use the serve function.

Modules

cache
catalog

Persistent metadata storage for the coordinator.

client
command
coord

Coordination of installed views, available timestamps, and compacted timestamps.

error
id_alloc
session

Per-connection configuration parameters and state.

sink_connector
timestamp
util

Structs

CacheConfig

Configures the coordinator's source caching.

Client

A coordinator client.

Config

Configures a coordinator.

ConnClient

A coordinator client that is bound to a connection.

Handle

A handle to a running coordinator.

LoggingConfig

Configures dataflow worker logging.

SessionClient

A coordinator client that is bound to a connection.

Enums

Cancelled

The state of a cancellation request.

CoordError

Errors that can occur in the coordinator.

ExecuteResponse

The response to SessionClient::execute.

StartupMessage

Messages in a StartupResponse.

Functions

serve

Serves the coordinator based on the provided configuration.