pub struct SsoImport;Expand description
The import kind.
Trait Implementations§
Source§impl JobKind for SsoImport
impl JobKind for SsoImport
Source§fn key(order: &ImportOrder) -> &str
fn key(order: &ImportOrder) -> &str
The account: one import per account at a time.
Source§const NAME: &'static str = "sso-import"
const NAME: &'static str = "sso-import"
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 = ImportOrder
type Order = ImportOrder
What was asked for, carried on the job so the worker can hand it
back to
JobKind::run minutes later. Read moreSource§type Report = ImportReport
type Report = ImportReport
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: &ImportOrder,
report: &Reporter<SsoImport>,
) -> Result<(), String>
fn run( &self, order: &ImportOrder, report: &Reporter<SsoImport>, ) -> 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 Freeze for SsoImport
impl RefUnwindSafe for SsoImport
impl Send for SsoImport
impl Sync for SsoImport
impl Unpin for SsoImport
impl UnsafeUnpin for SsoImport
impl UnwindSafe for SsoImport
Blanket Implementations§
impl<T> Allocation for T
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