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
47
48
49
50
51
52
53
54
55
56
57
58

//! Convert retained replay DTOs into passive facts without interpreting release safety.

use crate::fleet_ensure::view::release::receipts::{
    ReleaseAccountingFacts, ReleaseIntentFact, ReleaseIntentState, ReleaseReplayFacts,
    ReleaseReplayState,
};
use canic_core::dto::release_receipts::{
    ReplayReleaseEntry, ReplayReleaseIntent, ReplayReleaseIntentState, ReplayReleasePhase,
    ReplayReleaseRecoveryReason,
};

pub(in crate::fleet_ensure) fn assessment_facts(entry: &ReplayReleaseEntry) -> ReleaseReplayFacts {
    let status = match entry.phase {
        ReplayReleasePhase::Reserved => ReleaseReplayState::Reserved,
        ReplayReleasePhase::ExternalEffectInFlight => ReleaseReplayState::ExternalEffectInFlight,
        ReplayReleasePhase::Committed => ReleaseReplayState::Committed,
        ReplayReleasePhase::RecoveryRequired(reason) => match reason {
            ReplayReleaseRecoveryReason::ExternalEffectStatusUnknown => {
                ReleaseReplayState::ExternalEffectStatusUnknown
            }
            ReplayReleaseRecoveryReason::ComponentChildLifecycleInterrupted => {
                ReleaseReplayState::ComponentChildLifecycleInterrupted
            }
            ReplayReleaseRecoveryReason::ResponseCommitFailed => {
                ReleaseReplayState::ResponseCommitFailed
            }
            ReplayReleaseRecoveryReason::CostSettlementFailed => {
                ReleaseReplayState::CostSettlementFailed
            }
        },
    };
    ReleaseReplayFacts {
        slot: entry.slot,
        operation_id: entry.operation_id,
        status,
        accounting: entry
            .cost_guard_settlement
            .as_ref()
            .map(|settlement| ReleaseAccountingFacts {
                quota: intent_fact(settlement.quota_intent_id, settlement.quota.as_ref()),
                reservation: intent_fact(
                    settlement.reservation_intent_id,
                    settlement.reservation.as_ref(),
                ),
            }),
    }
}

fn intent_fact(intent_id: u64, intent: Option<&ReplayReleaseIntent>) -> ReleaseIntentFact {
    ReleaseIntentFact {
        intent_id,
        state: intent.map_or(ReleaseIntentState::Missing, |intent| match intent.state {
            ReplayReleaseIntentState::Pending => ReleaseIntentState::Pending,
            ReplayReleaseIntentState::Committed => ReleaseIntentState::Committed,
            ReplayReleaseIntentState::Aborted => ReleaseIntentState::Aborted,
        }),
    }
}