canic-host 0.110.53

Host-side App build and desired-state Fleet reconciliation library for Canic workspaces
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

//! Interpret replay phase independently of expired or released cost bookkeeping.

#[cfg(test)]
mod tests;

use crate::fleet_ensure::view::release::receipts::{
    ReleaseIntentState, ReleaseReplayAssessment, ReleaseReplayDisposition, ReleaseReplayFacts,
    ReleaseReplayState,
};

/// Preserve the original recovery owner; accounting alone never establishes payment outcome.
pub(in crate::fleet_ensure) fn assess_receipt(
    facts: &ReleaseReplayFacts,
) -> ReleaseReplayAssessment {
    let disposition = match &facts.status {
        ReleaseReplayState::Committed => ReleaseReplayDisposition::RecordedCompletion,
        ReleaseReplayState::Reserved => ReleaseReplayDisposition::ReservedOperation,
        ReleaseReplayState::ExternalEffectInFlight
        | ReleaseReplayState::ExternalEffectStatusUnknown => {
            ReleaseReplayDisposition::EffectReconciliation
        }
        ReleaseReplayState::ComponentChildLifecycleInterrupted => {
            ReleaseReplayDisposition::ChildLifecycleRecovery
        }
        ReleaseReplayState::ResponseCommitFailed => ReleaseReplayDisposition::ResponseRecovery,
        ReleaseReplayState::CostSettlementFailed => ReleaseReplayDisposition::AccountingRecovery,
    };
    let mut pending_intents = Vec::new();
    let mut missing_intents = Vec::new();
    if let Some(accounting) = facts.accounting {
        for intent in [accounting.quota, accounting.reservation] {
            match intent.state {
                ReleaseIntentState::Pending => pending_intents.push(intent.intent_id),
                ReleaseIntentState::Missing => missing_intents.push(intent.intent_id),
                ReleaseIntentState::Committed | ReleaseIntentState::Aborted => {}
            }
        }
    }
    ReleaseReplayAssessment {
        slot: facts.slot,
        operation_id: facts.operation_id,
        disposition,
        pending_intents,
        missing_intents,
    }
}