assemblyline_models/messages/
mod.rs

1use serde::{Deserialize, Serialize};
2
3use crate::Sid;
4
5pub mod dispatching;
6pub mod changes;
7pub mod task;
8pub mod submission;
9pub mod ingest_heartbeat;
10pub mod service_heartbeat;
11pub mod dispatcher_heartbeat;
12
13
14#[derive(Serialize, Deserialize, PartialEq, Eq)]
15#[serde(rename_all="lowercase")]
16pub enum ArchiveAction {
17    Archive,
18    Resubmit,
19}
20
21#[derive(Serialize, Deserialize)]
22pub struct ArchivedMessage {
23    pub action: ArchiveAction,
24    pub sid: Option<Sid>,
25}
26
27impl ArchivedMessage {
28    pub fn archive() -> Self {
29        Self {action: ArchiveAction::Archive, sid: None}
30    }
31    pub fn resubmit(sid: Sid) -> Self {
32        Self {action: ArchiveAction::Resubmit, sid: Some(sid)}
33    }
34}
35
36#[derive(Serialize, Deserialize)]
37pub struct KillContainerCommand {
38    pub service: String,
39    pub container: String,
40}