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
pub struct TermDrainFactory;
impl DrainFactory for TermDrainFactory {
fn from_config(&self, config: &config::Output) -> Result<Option<Drain>, String> {
let type_ = config.get("type").ok_or("output type missing")?;
if type_ != "term" {
return Ok(None)
}
let decorator = slog_term::TermDecorator::new();
let decorator = match config.get("use_stdout").map_or("false", |v| v.as_str()) {
"true" => decorator.stdout(),
"false" => decorator.stderr(),
_ => return Err("use_stdout must be true or false".to_owned())
};
let decorator = match config.get("color").map_or("auto", |v| v.as_str()) {
"true" => decorator.force_color(),
"false" => decorator.force_plain(),
"auto" => decorator,
_ => return Err("color must be true, false, or auto".to_owned())
};
let utc = match config.get("timestamp").map_or("utc", |v| v.as_str()) {
"local" => false,
"utc" => true,
unknown => return Err(format!("unknown timestamp type: {}", unknown))
};
let format_str = config.get("format").ok_or("format_missing")?;
match format_str.as_str() {
"compact" => {
let format = slog_term::CompactFormat::new(decorator.build());
let format = if utc { format.use_utc_timestamp() } else {
format.use_local_timestamp() };
Ok(Some(Box::new(BoxErrorDrain(Mutex::new(format.build())))))
},
"full" =>
{
let format = slog_term::FullFormat::new(decorator.build());
let format = if utc { format.use_utc_timestamp() } else {
format.use_local_timestamp() };
Ok(Some(Box::new(BoxErrorDrain(Mutex::new(format.build())))))
},
_ => return Err(format!("unknown terminal format: {}", format_str))
}
}
}