pub struct Mirror { /* private fields */ }Expand description
The mirror kind. Everything the shared runner needs to know about a sync, and nothing else.
Trait Implementations§
Source§impl JobKind for Mirror
impl JobKind for Mirror
Source§fn key(order: &MirrorOrder) -> &str
fn key(order: &MirrorOrder) -> &str
The repository. A second registration for the same repository replaces the first, so a repository has at most one upstream and the path is the whole subject.
Source§const NAME: &'static str = "mirror"
const NAME: &'static str = "mirror"
The kind’s short name. It is the job-id prefix (
gc-7, purge-12,
mirror-3), the jera lane’s job kind (gc), and the noun in
every message this module writes — so an operator reading a stack dump
or a FAILED job knows what it was without a lookup.Source§type Order = MirrorOrder
type Order = MirrorOrder
What was asked for, carried on the job so the worker can hand it
back to
JobKind::run minutes later. Read moreSource§type Report = MirrorReport
type Report = MirrorReport
What the job produced, in the kind’s own words: a gc’s bytes, a
purge’s stores and gate, a mirror’s objects. Read more
Source§fn run(
&self,
order: &MirrorOrder,
report: &Reporter<Mirror>,
) -> Result<(), String>
fn run( &self, order: &MirrorOrder, report: &Reporter<Mirror>, ) -> Result<(), String>
Do the work. Runs on the lane’s blocking thread, outside the queue’s lock,
inside a
std::panic::catch_unwind. Read moreSource§const FINISHED_RETENTION: Duration = DEFAULT_FINISHED_RETENTION
const FINISHED_RETENTION: Duration = DEFAULT_FINISHED_RETENTION
How long a finished job of this kind stays readable. Read more
Source§const FINISHED_KEPT: usize = DEFAULT_FINISHED_KEPT
const FINISHED_KEPT: usize = DEFAULT_FINISHED_KEPT
Finished jobs of this kind kept regardless of age.
Source§fn settle(
&self,
_order: &Self::Order,
outcome: Result<(), String>,
_progress: &Reporter<Self>,
) -> (JobState, Option<String>)
fn settle( &self, _order: &Self::Order, outcome: Result<(), String>, _progress: &Reporter<Self>, ) -> (JobState, Option<String>)
How the job settles — and the hook for anything that must come back. Read more
Source§fn shutdown_error(&self) -> String
fn shutdown_error(&self) -> String
What a job refused by a shutting-down queue says. Read more
Auto Trait Implementations§
impl !RefUnwindSafe for Mirror
impl !UnwindSafe for Mirror
impl Freeze for Mirror
impl Send for Mirror
impl Sync for Mirror
impl Unpin for Mirror
impl UnsafeUnpin for Mirror
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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> 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