hara_native/work/
types.rs

1use super::*;
2
3/// Validated portable identifier for one native work run.
4#[derive(Clone, Debug, PartialEq, Eq, Hash)]
5pub struct WorkId(String);
6
7impl WorkId {
8    pub fn new(value: impl Into<String>) -> Result<Self, String> {
9        let value = value.into();
10        if value.trim().is_empty() {
11            return Err("work run ID cannot be blank".into());
12        }
13        Ok(Self(value))
14    }
15
16    pub fn as_str(&self) -> &str {
17        &self.0
18    }
19}
20
21impl fmt::Display for WorkId {
22    fn fmt(&self, formatter: &mut fmt::Formatter<'_>) -> fmt::Result {
23        formatter.write_str(&self.0)
24    }
25}
26
27/// Monotonic state of a live native work run.
28#[derive(Clone, Copy, Debug, PartialEq, Eq)]
29pub enum WorkRunState {
30    Queued,
31    Running,
32    Waiting,
33    Cancelling,
34    Completed,
35    Failed,
36    Cancelled,
37}
38
39impl WorkRunState {
40    pub fn terminal(self) -> bool {
41        matches!(self, Self::Completed | Self::Failed | Self::Cancelled)
42    }
43}
44
45/// Non-blocking status snapshot for a live work run.
46#[derive(Clone, Debug, PartialEq)]
47pub struct WorkRunStatus {
48    pub id: WorkId,
49    pub state: WorkRunState,
50    pub started_at_millis: u64,
51    pub finished_at_millis: Option<u64>,
52    pub error: Option<PromiseRejection>,
53    pub cancel_reason: Option<Value>,
54    pub parent_id: Option<WorkId>,
55    pub child_count: usize,
56    pub deadline_remaining_millis: Option<u64>,
57    pub detached: bool,
58}
59
60/// Process-host lifecycle metadata.
61#[derive(Clone, Debug, PartialEq, Eq)]
62pub struct WorkHostStatus {
63    pub state: &'static str,
64    pub run_count: usize,
65    pub queued_count: usize,
66}
67
68/// Submission-time scope and deadline options.
69#[derive(Clone, Debug, Default)]
70pub struct WorkOptions {
71    pub id: Option<WorkId>,
72    pub timeout: Option<Duration>,
73    pub deadline: Option<Instant>,
74    pub detached: bool,
75}
76
77impl WorkOptions {
78    pub fn with_id(id: impl Into<String>) -> Result<Self, String> {
79        Ok(Self {
80            id: Some(WorkId::new(id)?),
81            ..Self::default()
82        })
83    }
84}
hara_native/work/types.rs

hara_native/work/
types.rs
