chord_core/
output.rs

1use std::sync::Arc;
2
3pub use async_trait::async_trait;
4pub use chrono::{DateTime, Utc};
5
6use crate::case::CaseAsset;
7use crate::flow::Flow;
8use crate::task::{StageAsset, TaskAsset, TaskId};
9
10pub type Error = Box<dyn std::error::Error + Sync + Send>;
11
12#[async_trait]
13pub trait JobReporter: Sync + Send {
14    async fn task(
15        &self,
16        task_id: Arc<dyn TaskId>,
17        flow: Arc<Flow>,
18    ) -> Result<Box<dyn TaskReporter>, Error>;
19}
20
21#[async_trait]
22pub trait TaskReporter: Sync + Send {
23    async fn stage(&self, stage_id: &str) -> Result<Box<dyn StageReporter>, Error>;
24
25    async fn start(&mut self, time: DateTime<Utc>) -> Result<(), Error>;
26
27    async fn end(&mut self, task_asset: &dyn TaskAsset) -> Result<(), Error>;
28}
29
30#[async_trait]
31pub trait StageReporter: Sync + Send {
32    async fn start(&mut self, time: DateTime<Utc>) -> Result<(), Error>;
33
34    async fn report(&mut self, case_asset_vec: &Vec<Box<dyn CaseAsset>>) -> Result<(), Error>;
35
36    async fn end(&mut self, task_asset: &dyn StageAsset) -> Result<(), Error>;
37}
chord_core/output.rs

chord_core/
output.rs
