pub enum CreditRegistrationPhase {
Materialize,
Preconditions,
ResolveEnrolments,
Import,
Verify,
LegacyMirror,
StudentNotifications,
EnrolmentDiscovery,
LinkEmails,
ConfigValidation,
RetentionSweep,
LedgerSnapshot,
}Expand description
A pipeline phase. CreditRegistrationPhase::as_str is canonical: it is
credit_registration_phase_state.phase, the tick endpoint’s ?phase= and the audit log’s
target_phase.
Variants§
Materialize
Preconditions
ResolveEnrolments
Import
Verify
LegacyMirror
StudentNotifications
EnrolmentDiscovery
LinkEmails
ConfigValidation
RetentionSweep
LedgerSnapshot
Implementations§
Source§impl CreditRegistrationPhase
impl CreditRegistrationPhase
Sourcepub fn as_str(self) -> &'static str
pub fn as_str(self) -> &'static str
The phase’s canonical name; see CreditRegistrationPhase.
Sourcepub fn from_phase_name(name: &str) -> Option<Self>
pub fn from_phase_name(name: &str) -> Option<Self>
The phase Self::as_str names name, if any.
Sourcepub fn pipeline_index(self) -> usize
pub fn pipeline_index(self) -> usize
Where the phase sits in Self::ALL’s pipeline order, for sorting phases by it.
Sourcepub fn owned_states(self) -> &'static [CreditRegistrationState]
pub fn owned_states(self) -> &'static [CreditRegistrationState]
The ledger states this phase is the one to move a row out of.
Empty for the phases whose work is not a ledger state at all: materialize’s queue is
completions with no row yet, and the syncer’s phases work on course modules. Narrower than
what preconditions may claim, which is every non-terminal row: these are the states nothing
else advances. How many of their rows are waiting on the phase is Self::queue_depth.
Sourcepub fn queue_depth(
self,
depth_of: impl Fn(CreditRegistrationState) -> i64,
due_enrolment_checks: i64,
) -> i64
pub fn queue_depth( self, depth_of: impl Fn(CreditRegistrationState) -> i64, due_enrolment_checks: i64, ) -> i64
The live rows waiting on this phase: the Workers tab’s “queue depth it is responsible for”, and the depth the failing-phase alert asks about before calling a quiet phase wedged.
depth_of is the live count of a state. due_enrolment_checks stands in for
no_usable_enrolment, whose other rows wait for their schedule rather than for the phase.
Trait Implementations§
Source§impl Clone for CreditRegistrationPhase
impl Clone for CreditRegistrationPhase
Source§fn clone(&self) -> CreditRegistrationPhase
fn clone(&self) -> CreditRegistrationPhase
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for CreditRegistrationPhase
impl Debug for CreditRegistrationPhase
Source§impl Hash for CreditRegistrationPhase
impl Hash for CreditRegistrationPhase
Source§impl PartialEq for CreditRegistrationPhase
impl PartialEq for CreditRegistrationPhase
impl Copy for CreditRegistrationPhase
impl Eq for CreditRegistrationPhase
impl StructuralPartialEq for CreditRegistrationPhase
Auto Trait Implementations§
impl Freeze for CreditRegistrationPhase
impl RefUnwindSafe for CreditRegistrationPhase
impl Send for CreditRegistrationPhase
impl Sync for CreditRegistrationPhase
impl Unpin for CreditRegistrationPhase
impl UnsafeUnpin for CreditRegistrationPhase
impl UnwindSafe for CreditRegistrationPhase
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§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>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
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>,
Layered].