hedos-kernel 1.3.0

The hedos kernel: model records, registry, discovery, install planning, and resolution.
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
59
60
61
62
63
64
65
66
67
68
69

//! The progress and event types an install emits.

/// Download progress for an install: bytes so far, the total (when known), and
/// which file is in flight.
#[derive(Debug, Clone, PartialEq, Eq, Hash, Default)]
pub struct InstallProgress {
    /// Bytes downloaded so far.
    pub bytes_downloaded: i64,
    /// The total to download, if known.
    pub total_bytes: Option<i64>,
    /// Whether `total_bytes` is a partial/growing estimate (so no fraction).
    pub total_is_partial: bool,
    /// The file currently downloading, if any.
    pub current_file: Option<String>,
}

impl InstallProgress {
    /// The completed fraction in `[0, 1]`, or `None` when the total is unknown,
    /// zero, or only a partial estimate.
    pub fn fraction(&self) -> Option<f64> {
        let total = self.total_bytes?;
        if total <= 0 || self.total_is_partial {
            return None;
        }
        Some((self.bytes_downloaded as f64 / total as f64).clamp(0.0, 1.0))
    }
}

/// A lifecycle event for an install job.
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum InstallEvent {
    /// Waiting to start.
    Queued,
    /// Resolving the plan before transfer.
    Preparing,
    /// A human-readable status line.
    Status(String),
    /// Download progress.
    Progress(InstallProgress),
    /// Completed successfully.
    Done,
    /// Failed, with a message.
    Failed {
        /// Why it failed.
        message: String,
    },
    /// Cancelled by the user.
    Cancelled,
}

impl InstallEvent {
    /// Whether this event ends the job (done/failed/cancelled).
    pub fn is_terminal(&self) -> bool {
        matches!(
            self,
            InstallEvent::Done | InstallEvent::Failed { .. } | InstallEvent::Cancelled
        )
    }
}

/// What a provider's transfer emits while running (before the terminal event is
/// synthesized by the install service).
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum InstallStreamEvent {
    /// A status line.
    Status(String),
    /// Download progress.
    Progress(InstallProgress),
}