pub struct Client {
cmd_tx: UnboundedSender<Command>,
id_alloc: Arc<IdAllocator<u32>>,
}
Expand description
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<u32>>
Implementations
sourceimpl Client
impl Client
pub(crate) fn new(cmd_tx: UnboundedSender<Command>) -> Client
sourcepub fn new_conn(&self) -> Result<ConnClient, CoordError>
pub fn new_conn(&self) -> Result<ConnClient, CoordError>
Allocates a client for an incoming connection.
sourcepub async fn system_execute(
&self,
stmts: &str
) -> Result<SimpleExecuteResponse, CoordError>
pub async fn system_execute(
&self,
stmts: &str
) -> Result<SimpleExecuteResponse, CoordError>
Executes SQL statements, as if by SessionClient::simple_execute
, as
a system user.
sourcepub async fn system_execute_one(
&self,
stmt: &str
) -> Result<SimpleResult, CoordError>
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
Auto Trait Implementations
impl !RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl !UnwindSafe for Client
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
sourceimpl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
impl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
sourceimpl<P, R> ProtoType<R> for P where
R: RustType<P>,
impl<P, R> ProtoType<R> for P where
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See RustType::from_proto
.
sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See RustType::into_proto
.
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more