Skip to main content

stasis/application/runtime/
runtime_job_identity_context.rs

1use crate::domain::runtime::job::Job;
2
3#[derive(Clone)]
4pub struct RuntimeJobIdentityContext {
5    pub job_id: String,
6    pub correlation_id: String,
7    pub causation_id: String,
8    pub trace_id: String,
9    pub sttp_input_node_id: String,
10}
11
12impl From<&Job> for RuntimeJobIdentityContext {
13    fn from(job: &Job) -> Self {
14        Self {
15            job_id: job.id.clone(),
16            correlation_id: job.correlation_id.clone(),
17            causation_id: job.causation_id.clone(),
18            trace_id: job.trace_id.clone(),
19            sttp_input_node_id: job.sttp_input_node_id.clone(),
20        }
21    }
22}