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

catalog

Persistent metadata storage for the coordinator.

session

Per-connection configuration parameters and state.

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.

PersistenceConfig
SessionClient

A coordinator client that is bound to a connection.

StartupResponse

The response to ConnClient::startup.

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.