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
|
pub mod container;
use ipc_channel::ipc;
use serde::{Deserialize, Serialize};
use std::collections::{HashMap, HashSet};
use crate::{types::*, util::error::*};
#[derive(Clone, Debug, Deserialize, Serialize, PartialEq, Eq, Hash)]
#[serde(rename_all = "snake_case")]
pub enum Dependency {
Fetch { name: String, sha256: StringHash },
Task { output: ArchiveHash, path: String },
}
#[derive(Clone, Debug, Deserialize, Serialize)]
pub struct Task {
pub label: String,
pub command: String,
pub inherit: Vec<LayerHash>,
pub depends: HashSet<Dependency>,
pub outputs: HashMap<String, String>,
}
#[derive(Clone, Debug, Deserialize, Serialize)]
pub struct TaskOutput {
pub input_hash: InputHash,
pub layer: Option<LayerHash>,
pub outputs: HashMap<String, ArchiveHash>,
}
pub trait Runner {
fn spawn(&self, task: &Task) -> ipc::IpcReceiver<Result<TaskOutput>>;
}
|
