Crate coord[−][src]
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.
Modules
Persistent metadata storage for the coordinator.
Coordination of installed views, available timestamps, compacted timestamps, and transactions.
Materialize-specific persistence configuration.
Per-connection configuration parameters and state.
Implementations around supporting the TAIL protocol with the dataflow layer
Macros
Structs
A coordinator client.
Configures a coordinator.
A coordinator client that is bound to a connection.
A handle to a running coordinator.
Configures dataflow worker logging.
Configuration of the persistence runtime and features.
A coordinator client that is bound to a connection.
The response to ConnClient::startup.
Enums
The state of a cancellation request.
Errors that can occur in the coordinator.
The response to SessionClient::execute.
Messages in a StartupResponse.
Functions
Serves the coordinator based on the provided configuration.