pub(crate) struct Job<R> {
req: R,
ack: Sender<Result<(), Rejected>>,
wal_seq: Option<u64>,
}Fields§
§req: R§ack: Sender<Result<(), Rejected>>§wal_seq: Option<u64>The log sequence this export was framed at, if there is a log. The
flusher collects them per block and asks Wal::watermark_for what
wal_hi that set permits — not the maximum over the block, which would
step over an older frame a sibling shard is still holding.
Auto Trait Implementations§
impl<R> !RefUnwindSafe for Job<R>
impl<R> !UnwindSafe for Job<R>
impl<R> Freeze for Job<R>where
R: Freeze,
impl<R> Send for Job<R>where
R: Send,
impl<R> Sync for Job<R>where
R: Sync,
impl<R> Unpin for Job<R>where
R: Unpin,
impl<R> UnsafeUnpin for Job<R>where
R: UnsafeUnpin,
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].