Struct coord::Client

pub struct Client {
    cmd_tx: UnboundedSender<Command>,
    id_alloc: Arc<IdAllocator>,
}

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

cmd_tx: UnboundedSender<Command>

id_alloc: Arc<IdAllocator>

Implementations

impl Client

pub(crate) fn new(cmd_tx: UnboundedSender<Command>) -> Client

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

Allocates a client for an incoming connection.

pub async fn system_execute(
    &self,
    stmts: &str
) -> Result<SimpleExecuteResponse, CoordError>

Executes SQL statements, as if by SessionClient::simple_execute, as a system user.

pub async fn system_execute_one(
    &self,
    stmt: &str
) -> Result<SimpleResult, CoordError>

Like Client::system_execute, but for cases when stmt is known to contain just one statement.

Panics

Panics if stmt parses to more than one SQL statement.

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.