pub struct Gc { /* private fields */ }Expand description
The gc kind. Everything the shared runner needs to know about a gc, and nothing else.
Trait Implementations§
Source§impl JobKind for Gc
impl JobKind for Gc
Source§type Order = String
type Order = String
The repository, <namespace>/<name>. A gc has nothing else to be told:
there are no options, so the order and the subject are the same string.
Source§fn run(&self, path: &String, report: &Reporter<Gc>) -> Result<(), String>
fn run(&self, path: &String, report: &Reporter<Gc>) -> Result<(), String>
Call the runner and record what it freed.
A gc reports nothing on the way through — no Reporter::progress —
because as far as a caller is concerned it is one indivisible act, and a
fabricated 0/1 would be a progress bar that lies. The bytes are known
only at the end, which is when they are written.
Source§const NAME: &'static str = "gc"
const NAME: &'static str = "gc"
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 Report = GcReport
type Report = GcReport
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 key(order: &String) -> &str
fn key(order: &String) -> &str
The subject, and therefore the dedup key and the status key. Read more
Source§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 Gc
impl !UnwindSafe for Gc
impl Freeze for Gc
impl Send for Gc
impl Sync for Gc
impl Unpin for Gc
impl UnsafeUnpin for Gc
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