dora-core 1.0.0

`dora` goal is to be a low latency, composable, and distributed data flow.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use std::future::Future;

pub use dora_message::common::LogLevelOrStdout;

pub trait BuildLogger: Send {
    type Clone: BuildLogger + 'static;

    fn log_message(
        &mut self,
        level: impl Into<LogLevelOrStdout> + Send,
        message: impl Into<String> + Send,
    ) -> impl Future<Output = ()> + Send;

    fn log_stdout(&mut self, message: impl Into<String> + Send) -> impl Future<Output = ()> + Send {
        self.log_message(LogLevelOrStdout::Stdout, message)
    }

    fn try_clone(&self) -> impl Future<Output = eyre::Result<Self::Clone>> + Send;
}