dora-core 0.5.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
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

use std::future::Future;

use dora_message::BuildId;
pub use dora_message::common::LogLevelOrStdout;
use dora_message::id::NodeId;

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;
}

/// A [`BuildLogger`] that forwards messages to the `tracing` crate.
///
/// Used by the daemon's RPC server path where a full `DaemonLogger`
/// (with TCP connection) is not available.
#[derive(Clone)]
pub struct TracingBuildLogger {
    build_id: BuildId,
    node_id: NodeId,
}

impl TracingBuildLogger {
    pub fn new(build_id: BuildId, node_id: NodeId) -> Self {
        Self { build_id, node_id }
    }
}

impl BuildLogger for TracingBuildLogger {
    type Clone = TracingBuildLogger;

    async fn log_message(
        &mut self,
        level: impl Into<LogLevelOrStdout> + Send,
        message: impl Into<String> + Send,
    ) {
        let message = message.into();
        match level.into() {
            LogLevelOrStdout::Stdout => {
                tracing::info!(build_id = %self.build_id, node_id = %self.node_id, "{message}");
            }
            LogLevelOrStdout::LogLevel(dora_message::common::LogLevel::Error) => {
                tracing::error!(build_id = %self.build_id, node_id = %self.node_id, "{message}");
            }
            LogLevelOrStdout::LogLevel(dora_message::common::LogLevel::Warn) => {
                tracing::warn!(build_id = %self.build_id, node_id = %self.node_id, "{message}");
            }
            LogLevelOrStdout::LogLevel(dora_message::common::LogLevel::Info) => {
                tracing::info!(build_id = %self.build_id, node_id = %self.node_id, "{message}");
            }
            _ => {
                tracing::debug!(build_id = %self.build_id, node_id = %self.node_id, "{message}");
            }
        }
    }

    async fn try_clone(&self) -> eyre::Result<Self::Clone> {
        Ok(self.clone())
    }
}