Crate mz_adapter
source · [−]Expand description
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:
- Launching the dataflow workers.
- Periodically allowing the dataflow workers to compact existing data.
- Executing SQL queries from clients by parsing and planning them, sending the plans to the dataflow layer, and then streaming the results back to the client.
- Assigning timestamps to incoming source data.
The main interface to the coordinator is Client
. To start a coordinator,
use the serve
function.
Re-exports
pub use crate::client::Client;
pub use crate::client::ConnClient;
pub use crate::client::Handle;
pub use crate::client::SessionClient;
Modules
Persistent metadata storage for the coordinator.
Per-connection configuration parameters and state.
Macros
Enforces critical section invariants for functions that perform writes to
tables, e.g. INSERT
, UPDATE
.
Structs
Configures a coordinator.
The response to ConnClient::startup
.
Enums
Errors that can occur in the coordinator.
The state of a cancellation request.
The response to SessionClient::execute
.
The response from a Peek
, with row multiplicities represented in unary.
Messages in a StartupResponse
.
Constants
A dummy availability zone to use when no availability zones are explicitly specified.
Functions
Serves the coordinator based on the provided configuration.