logup 0.1.0

Logup is a UNIX-style command that can be used to pipe stdout logs to location on disk or in the cloud without the need of an agent, logrotate, systemd or other configuration files
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

use async_trait::async_trait;
use std::io::Error;
use std::time::SystemTime;
use tokio::fs::File;
use tokio::io::{AsyncReadExt, Stdin};

#[async_trait]
pub trait AsyncLogReader {
    async fn read_logs(
        &mut self,
        buf: &mut [u8],
        time: &mut SystemTime,
    ) -> Result<usize, std::io::Error>;
}

#[async_trait]
impl AsyncLogReader for Stdin {
    async fn read_logs(&mut self, buf: &mut [u8], time: &mut SystemTime) -> Result<usize, Error> {
        *time = SystemTime::now();
        self.read(buf).await
    }
}

#[async_trait]
impl AsyncLogReader for File {
    async fn read_logs(&mut self, buf: &mut [u8], time: &mut SystemTime) -> Result<usize, Error> {
        *time = SystemTime::now();
        self.read(buf).await
    }
}

#[async_trait]
impl<T: AsyncLogReader + Send + ?Sized> AsyncLogReader for Box<T> {
    async fn read_logs(&mut self, buf: &mut [u8], time: &mut SystemTime) -> Result<usize, Error> {
        (**self).read_logs(buf, time).await
    }
}