pub struct Handle {
pub(crate) cluster_id: Uuid,
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
cluster_id: Uuid
session_id: Uuid
start_instant: Instant
_thread: JoinOnDropHandle<()>
Implementations
sourceimpl Handle
impl Handle
sourcepub fn cluster_id(&self) -> Uuid
pub fn cluster_id(&self) -> Uuid
Returns the cluster ID associated with this coordinator.
The cluster ID is recorded in the data directory when it is first created and persists until the data directory is deleted.
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
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