Skip to main content

Module client

Module client 

Source

Structs§

Client
A coordinator client.
Handle
A handle to a running coordinator.
RecordFirstRowStream
A wrapper around a Stream of PeekResponseUnary that records when it sees the first row data in the given histogram. It also keeps track of whether we have already observed the end of the underlying stream.
SessionClient
A coordinator client that is bound to a connection.
Timeout 🔒

Enums§

TimeoutType

Functions§

is_read_then_write_statement 🔒
Whether a statement is one the frontend read-then-write path sequences.
prohibited_in_transaction 🔒
Builds the error for DML that cannot run in a transaction block, mirroring the coordinator’s redaction in handle_execute: statements that can carry sensitive literals are redacted because the error message is persisted in mz_statement_execution_history.
redact_sql_for_logging
Renders SQL for statement arrival logging: parsed and displayed with its literals redacted, which is the same redaction the statement log applies. When the text does not parse or exceeds the statement batch size limit, a placeholder with the byte length is returned. Raw text is never returned, so a statement that crashes the parser is not captured, an accepted limitation.