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
|
use super::{formats::Format, aggregators::Aggregator};
use super::super::LogResult;
use std::{io::Write, sync::Mutex};
pub struct Pipeline {
format: Box<dyn Format>,
aggregator: Box<dyn Aggregator>,
writer: Mutex<Box<dyn Write + Send>>,
}
impl Pipeline {
pub fn new<W: Write + 'static + Send, F: Format + 'static, A: Aggregator + 'static>(writer: W, format: F, aggregator: A) -> Pipeline {
Pipeline {
format: Box::new(format),
aggregator: Box::new(aggregator),
writer: Mutex::new(Box::new(writer)),
}
}
pub fn push_item(&self, item: &LogResult) {
let mut writer = self.writer.lock().unwrap();
self.aggregator.push_item(item, &*self.format, &mut *writer);
}
}
|
