Struct mz_adapter::client::Handle
source · pub struct Handle {
pub(crate) session_id: Uuid,
pub(crate) start_instant: Instant,
pub(crate) _thread: JoinOnDropHandle<()>,
}
Expand description
A handle to a running coordinator.
The coordinator runs on its own thread. Dropping the handle will wait for
the coordinator’s thread to exit, which will only occur after all
outstanding Client
s for the coordinator have dropped.
Fields§
§session_id: Uuid
§start_instant: Instant
§_thread: JoinOnDropHandle<()>
Implementations§
source§impl Handle
impl Handle
sourcepub fn session_id(&self) -> Uuid
pub fn session_id(&self) -> Uuid
Returns the session ID associated with this coordinator.
The session ID is generated on coordinator boot. It lasts for the lifetime of the coordinator. Restarting the coordinator will result in a new session ID.
sourcepub fn start_instant(&self) -> Instant
pub fn start_instant(&self) -> Instant
Returns the instant at which the coordinator booted.
Auto Trait Implementations§
impl !RefUnwindSafe for Handle
impl Send for Handle
impl Sync for Handle
impl Unpin for Handle
impl !UnwindSafe for Handle
Blanket Implementations§
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.