2024-01-23 16:40:07 +08:00
|
|
|
use std::io::{Read, Write};
|
|
|
|
|
|
|
|
use entry::Entry;
|
|
|
|
|
|
|
|
pub mod entry;
|
|
|
|
mod error;
|
|
|
|
pub mod layer;
|
|
|
|
pub mod processor;
|
|
|
|
|
|
|
|
pub use error::Error;
|
|
|
|
|
|
|
|
pub struct Trace<W: Write> {
|
|
|
|
writer: W,
|
2024-01-23 23:52:48 +08:00
|
|
|
receiver: tokio::sync::mpsc::UnboundedReceiver<Entry>,
|
2024-01-23 16:40:07 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
pub struct TraceReader<R: Read> {
|
|
|
|
reader: R,
|
|
|
|
}
|
|
|
|
|
|
|
|
impl<R: Read> TraceReader<R> {
|
|
|
|
pub fn new(reader: R) -> Self {
|
|
|
|
Self { reader }
|
|
|
|
}
|
|
|
|
|
|
|
|
fn read(&mut self) -> Option<Result<Entry, Error>> {
|
|
|
|
serde_json::Deserializer::from_reader(&mut self.reader)
|
|
|
|
.into_iter()
|
|
|
|
.next()
|
|
|
|
.map(|res| res.map_err(Into::into))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
impl<R: Read> Iterator for TraceReader<R> {
|
|
|
|
type Item = Result<Entry, Error>;
|
|
|
|
|
|
|
|
fn next(&mut self) -> Option<Self::Item> {
|
|
|
|
self.read()
|
|
|
|
}
|
|
|
|
}
|