Enum LifecycleEvent 

pub enum LifecycleEvent {
    DemandObserved {
        policy: PolicyId,
        demand: u32,
        not_matched: u32,
        unresolvable: u32,
        complete: bool,
    },
    TargetUnreadable {
        policy: PolicyId,
        reason: &'static str,
    },
    Allocated {
        policy: PolicyId,
        demand: u32,
        desired: u16,
        active_owned: u16,
        headroom: u16,
        to_start: u16,
        limiting: LimitingFactor,
    },
    MonitorOnlySkipped {
        policy: PolicyId,
    },
    RunnerStarted {
        policy: PolicyId,
        attempt: AttemptId,
    },
    RunnerStartFailed {
        policy: PolicyId,
        reason: &'static str,
    },
    AllocationDeferred {
        policy: PolicyId,
        count: u16,
    },
    AttemptsUnreadable {
        reason: &'static str,
    },
    AttemptCleaned {
        policy: PolicyId,
        attempt: AttemptId,
        outcome: OutcomeKind,
    },
    AttemptCleanFailed {
        policy: PolicyId,
        attempt: AttemptId,
        reason: &'static str,
    },
    ScaleDownRefused {
        policy: PolicyId,
        attempt: AttemptId,
    },
    PollScheduled {
        retry_in_ms: u64,
        pace: PollPace,
    },
}

What g2’s activity view and the local log sink see.

Every field is an identifier, a count, a duration, or a &'static str drawn from a closed set. There is no String anywhere in this enum, which is what makes “no emitted event contains a token, a JIT blob, or a credential header” a property of the type rather than a discipline each call site has to keep. tests::no_emitted_event_can_carry_a_credential renders every variant through d1’s scrubber and asserts nothing changes, with a positive control so the assertion cannot pass vacuously.

Variants

DemandObserved

A demand poll answered for one target.

Fields

policy: PolicyId

demand: u32

Queued jobs this policy’s routing labels match. The number clamped.

not_matched: u32

Queued jobs whose required labels this policy does not carry.

Never demand. Reported because the difference between this and demand is the whole value of the label filtering, and an operator wondering why a busy repository started no runners is owed it.

unresolvable: u32

Queued jobs whose runs-on could not be resolved statically.

b1 requires these be “reported as unresolvable rather than silently counted or silently dropped”: counting one would start a runner for a job that may not be ours, and dropping it would hide a workflow this host can never serve. A count rather than the reasons themselves because this type is Copy, and c4 logs the reasons where it builds them.

complete: bool

false when the count is a floor rather than a total.

TargetUnreadable

A target could not be polled, so its policies start nothing this pass.

Fields

policy: PolicyId

reason: &'static str

Allocated

One policy’s share of the pass.

Fields

policy: PolicyId

demand: u32

desired: u16

active_owned: u16

headroom: u16

to_start: u16

limiting: LimitingFactor

MonitorOnlySkipped

A monitor-only policy was skipped entirely, before any demand request was issued for it (D19).

Fields

policy: PolicyId

RunnerStarted

One runtime was created and one runner started.

Fields

policy: PolicyId

attempt: AttemptId

RunnerStartFailed

One runner could not be started.

Fields

policy: PolicyId

reason: &'static str

AllocationDeferred

The allocation lock was not free, so count runners this policy was granted were not created this pass.

Fields

policy: PolicyId

count: u16

AttemptsUnreadable

The host’s attempt set could not be read at all.

Distinct from an empty set on purpose, and the whole reason RunnerLauncher::attempts is fallible: the two produce the same number and demand opposite actions.

Fields

reason: &'static str

AttemptCleaned

A terminal attempt’s runtime was removed.

Fields

policy: PolicyId

attempt: AttemptId

outcome: OutcomeKind

AttemptCleanFailed

A terminal attempt’s runtime could not be removed. It will be retried on the next pass, and this is what keeps that retry from being silent.

Fields

policy: PolicyId

attempt: AttemptId

reason: &'static str

ScaleDownRefused

Scale-down declined to remove a runner that is executing a job.

Fields

policy: PolicyId

attempt: AttemptId

PollScheduled

When the next poll is, and why then.

Fields

retry_in_ms: u64

pace: PollPace

Implementations

impl LifecycleEvent

pub const fn name(&self) -> &'static str

A fixed name, for the event field d1’s sink allows verbatim.

pub const fn policy(&self) -> Option<PolicyId>

Which policy this event is about.

Trait Implementations

impl Clone for LifecycleEvent

fn clone(&self) -> LifecycleEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for LifecycleEvent

impl Debug for LifecycleEvent

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

Formats the value using the given formatter.

impl Display for LifecycleEvent

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

Formats the value using the given formatter.

impl Eq for LifecycleEvent

impl PartialEq for LifecycleEvent

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for LifecycleEvent