pub struct GrpcLivenessTarget {
pub worker_id: WorkerId,
pub sender: WorkerTaskSender,
}Expand description
One gRPC-delivered worker the probe pings on a round.
The liminal counterpart (LivenessTarget) carries a
connection pid because a liminal worker is addressed by its connection. A
gRPC worker has no such handle: its stream lives inside a tonic task and the
registration’s sender is the only way to reach it, so that sender IS the
address.
Fields§
§worker_id: WorkerIdRegistry identity of the worker being probed.
sender: WorkerTaskSenderThe worker’s stream delivery channel — the same one dispatches use.
Trait Implementations§
Source§impl Clone for GrpcLivenessTarget
impl Clone for GrpcLivenessTarget
Source§fn clone(&self) -> GrpcLivenessTarget
fn clone(&self) -> GrpcLivenessTarget
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for GrpcLivenessTarget
impl RefUnwindSafe for GrpcLivenessTarget
impl Send for GrpcLivenessTarget
impl Sync for GrpcLivenessTarget
impl Unpin for GrpcLivenessTarget
impl UnsafeUnpin for GrpcLivenessTarget
impl UnwindSafe for GrpcLivenessTarget
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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> IntoMaybeUndefined<T> for T
impl<T> IntoMaybeUndefined<T> for T
Source§fn into_maybe_undefined(self) -> MaybeUndefined<T>
fn into_maybe_undefined(self) -> MaybeUndefined<T>
Converts this value into a three-state builder argument.
Source§impl<T> IntoOption<T> for T
impl<T> IntoOption<T> for T
Source§fn into_option(self) -> Option<T>
fn into_option(self) -> Option<T>
Converts this value into an optional builder argument.
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