godwit-daemon 0.1.10

A daemon runner for GodWit.
Documentation 
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use crate::core::{Backend, BackendArgs, ExternalBackends, Ops};
use crate::errors::{BackendError, DelegateError};
use serde::{Deserialize, Serialize};
use std::fmt;

#[derive(Debug, PartialEq, Serialize, Deserialize, Copy, Clone)]
pub enum HandleOps {
	Run,
	Kill,
	Heartbeat,
}

impl Default for HandleOps {
	fn default() -> Self {
		HandleOps::Heartbeat
	}
}

impl fmt::Display for HandleOps {
	fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
		write!(f, "{:?}", self)
	}
}

pub fn handle(
	handler: HandleOps,
	func: Option<Ops>,
	application: Option<String>,
	refresh: bool,
) -> Result<(), DelegateError> {
	match handler {
		HandleOps::Run => delegate(func.unwrap(), application.unwrap().as_ref(), refresh),
		HandleOps::Kill => terminate(None, func, application),
		HandleOps::Heartbeat => heartbeat(),
	}
}

pub fn delegate(func: Ops, application: &str, refresh: bool) -> Result<(), DelegateError> {
	match func {
		Ops::Trace => ExternalBackends::from_dir("lib/backends")?
			.backends
			.get(application)
			.ok_or_else(|| BackendError::NotFound {
				backend_str: application.to_string(),
			})?
			.trace(BackendArgs { refresh })
			.map_err(Into::into),
	}
}

pub fn terminate(
	thread_id: Option<u16>,
	operation: Option<Ops>,
	application: Option<String>,
) -> Result<(), DelegateError> {
	Ok(())
}

pub fn heartbeat() -> Result<(), DelegateError> {
	Ok(())
}