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