Struct mz_coord::client::ConnClient
source · [−]Expand description
A coordinator client that is bound to a connection.
The ConnClient
automatically allocates an ID for the connection when
it is created, and frees that ID for potential reuse when it is dropped.
See also Client
.
Fields
conn_id: u32
inner: Client
Implementations
sourceimpl ConnClient
impl ConnClient
sourcepub async fn startup(
self,
session: Session,
create_user_if_not_exists: bool
) -> Result<(SessionClient, StartupResponse), CoordError>
pub async fn startup(
self,
session: Session,
create_user_if_not_exists: bool
) -> Result<(SessionClient, StartupResponse), CoordError>
Upgrades this connection client to a session client.
A session is a connection that has successfully negotiated parameters, like the user. Most coordinator operations are available only after upgrading a connection to a session.
Returns a new client that is bound to the session and a response containing various details about the startup.
sourcepub async fn cancel_request(&mut self, conn_id: u32, secret_key: u32)
pub async fn cancel_request(&mut self, conn_id: u32, secret_key: u32)
Cancels the query currently running on another connection.
async fn send<T, F>(&mut self, f: F) -> T where
F: FnOnce(Sender<T>) -> Command,
Trait Implementations
sourceimpl Debug for ConnClient
impl Debug for ConnClient
Auto Trait Implementations
impl !RefUnwindSafe for ConnClient
impl Send for ConnClient
impl Sync for ConnClient
impl Unpin for ConnClient
impl !UnwindSafe for ConnClient
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<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> 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