Struct mz_adapter::client::Client

pub struct Client {
    build_info: &'static BuildInfo,
    inner_cmd_tx: UnboundedSender<Command>,
    id_alloc: Arc<IdAllocator<ConnectionId>>,
    metrics: Metrics,
}

A coordinator client.

A coordinator client is a simple handle to a communication channel with the coordinator. It can be cheaply cloned.

Clients keep the coordinator alive. The coordinator will not exit until all outstanding clients have dropped.

Fields

build_info: &'static BuildInfo

inner_cmd_tx: UnboundedSender<Command>

id_alloc: Arc<IdAllocator<ConnectionId>>

metrics: Metrics

Implementations

impl Client

pub(crate) fn new(
    build_info: &'static BuildInfo,
    cmd_tx: UnboundedSender<Command>,
    metrics: Metrics
) -> Client

pub fn new_conn(&self) -> Result<ConnClient, AdapterError>

Allocates a client for an incoming connection.

pub async fn introspection_execute_one(
    &self,
    sql: &str
) -> Result<Vec<Row>, Error>

Executes a single SQL statement that returns rows as the mz_introspection user.

pub fn metrics(&self) -> &Metrics

Returns the metrics associated with the adapter layer.

fn send(&self, cmd: Command)

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.