Struct CreditRegistrationPhaseRow 

pub struct CreditRegistrationPhaseRow {

    pub phase: String,
    pub process_name: String,
    pub expected_interval_secs: i32,
    pub last_heartbeat_at: Option<DateTime<Utc>>,
    pub last_run_started_at: Option<DateTime<Utc>>,
    pub last_run_finished_at: Option<DateTime<Utc>>,
    pub last_success_at: Option<DateTime<Utc>>,
    pub next_run_at: Option<DateTime<Utc>>,
    pub items_processed_last_run: Option<i32>,
    pub items_failed_last_run: Option<i32>,
    pub consecutive_failures: i32,
    pub last_error: Option<String>,
    pub paused_at: Option<DateTime<Utc>>,
    pub paused_by_user_id: Option<Uuid>,
    pub pause_reason: Option<String>,
    pub implemented: bool,
    pub seconds_since_heartbeat: Option<i64>,
    pub last_run_duration_secs: Option<i64>,
    pub heartbeat_late: bool,
    pub failing: bool,
    pub owned_states: Vec<CreditRegistrationState>,
    pub queue_depth: Option<i64>,
}

One phase as the Workers tab renders it.

Wider than CreditRegistrationPhaseStatus, which the pause/resume/run-now responses return: this one also carries the last error, the run window and the queue.

Fields

phase: String

process_name: String

The worker process whose loop runs the phase. Rows are grouped by it, because a dead pod makes every phase inside it go stale at once and that reads as one fault, not seven.

expected_interval_secs: i32

last_heartbeat_at: Option<DateTime<Utc>>

last_run_started_at: Option<DateTime<Utc>>

last_run_finished_at: Option<DateTime<Utc>>

last_success_at: Option<DateTime<Utc>>

next_run_at: Option<DateTime<Utc>>

items_processed_last_run: Option<i32>

items_failed_last_run: Option<i32>

consecutive_failures: i32

last_error: Option<String>

Our own wording or the study registry’s code, never its prose.

paused_at: Option<DateTime<Utc>>

paused_by_user_id: Option<Uuid>

pause_reason: Option<String>

implemented: bool

No implementation is registered for the phase yet, so it has never reported and will not.

seconds_since_heartbeat: Option<i64>

Computed server-side: a page comparing its own clock against a server timestamp misjudges this on a skewed client.

last_run_duration_secs: Option<i64>

heartbeat_late: bool

Always false while paused or never heartbeated.

failing: bool

owned_states: Vec<CreditRegistrationState>

The ledger states nothing but this phase moves a row out of. Empty for the phases whose work is not a ledger state: materialize waits on completions, the syncer’s phases on modules.

queue_depth: Option<i64>

Live rows in owned_states, or None where there are none to own — which is not the same as an empty queue.

Trait Implementations

impl Clone for CreditRegistrationPhaseRow

fn clone(&self) -> CreditRegistrationPhaseRow

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ComposeSchema for CreditRegistrationPhaseRow

fn compose(generics: Vec<RefOr<Schema>>) -> RefOr<Schema>

impl Debug for CreditRegistrationPhaseRow

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CreditRegistrationPhaseRow

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for CreditRegistrationPhaseRow

fn eq(&self, other: &CreditRegistrationPhaseRow) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for CreditRegistrationPhaseRow

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToSchema for CreditRegistrationPhaseRow

fn name() -> Cow<'static, str>

Return name of the schema.

fn schemas(schemas: &mut Vec<(String, RefOr<Schema>)>)

Implement reference [utoipa::openapi::schema::Schema]s for this type.

impl StructuralPartialEq for CreditRegistrationPhaseRow