pub struct PullRegistrationState {
pub is_ready: bool,
pub queues: Vec<PullQueueRegistrationState>,
}Expand description
Independent readiness snapshot returned by crate::Worker::pull_registration_state.
Fields§
§is_ready: boolTrue after a Step-and-RPC slot and, when reserved, an RPC-only slot register once. A permanent rejection with no registered stream of that kind clears readiness.
queues: Vec<PullQueueRegistrationState>Slot-kind snapshots sorted by label; the field name is retained for source compatibility.
Trait Implementations§
Source§impl Clone for PullRegistrationState
impl Clone for PullRegistrationState
Source§impl Debug for PullRegistrationState
impl Debug for PullRegistrationState
Auto Trait Implementations§
impl !RefUnwindSafe for PullRegistrationState
impl !UnwindSafe for PullRegistrationState
impl Forget for PullRegistrationState
impl Freeze for PullRegistrationState
impl Send for PullRegistrationState
impl Sync for PullRegistrationState
impl Unpin for PullRegistrationState
impl UnsafeUnpin for PullRegistrationState
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
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> 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