wp-log 0.4.0

Structured logging macros plus log4rs configuration helpers for WarpParse services
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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

// 统一日志 target，围绕 6 个域进行输出：
// ctrl  - 平台控制面，覆盖启动/调度/治理等生命周期事件。
// data  - 数据平面，覆盖 source/parse/connector/sink 的数据流处理。
// rule  - 规则与业务策略执行，包含插件/接口等扩展点。
// dfx   - 诊断与恢复能力，包含容错、兜底、应急处理。
// mtrc  - 指标与观测数据，记录性能、吞吐、容量等信息。
// kdb   - 知识库或知识图谱相关逻辑，集中管理特征/上下文。
//
// 为保证兼容，旧的 target 宏仍然导出，但已经标记为过期（#[deprecated]），
// 并在内部转发到新的域。迁移新日志时请直接使用新的 target 宏。

// ctrl 域（平台控制面）
#[macro_export]
macro_rules! trace_ctrl { ($($arg:tt)+) => { $crate::re_exports::log::trace!(target: "ctrl", $($arg)+) } }
#[macro_export]
macro_rules! debug_ctrl { ($($arg:tt)+) => { $crate::re_exports::log::debug!(target: "ctrl", $($arg)+) } }
#[macro_export]
macro_rules! info_ctrl  { ($($arg:tt)+) => { $crate::re_exports::log::info!( target: "ctrl", $($arg)+) } }
#[macro_export]
macro_rules! warn_ctrl  { ($($arg:tt)+) => { $crate::re_exports::log::warn!( target: "ctrl", $($arg)+) } }
#[macro_export]
macro_rules! error_ctrl { ($($arg:tt)+) => { $crate::re_exports::log::error!(target: "ctrl", $($arg)+) } }

// data 域（数据平面）
#[macro_export]
macro_rules! trace_data { ($($arg:tt)+) => { $crate::re_exports::log::trace!(target: "data", $($arg)+) } }
#[macro_export]
macro_rules! debug_data { ($($arg:tt)+) => { $crate::re_exports::log::debug!(target: "data", $($arg)+) } }
#[macro_export]
macro_rules! info_data  { ($($arg:tt)+) => { $crate::re_exports::log::info!( target: "data", $($arg)+) } }
#[macro_export]
macro_rules! warn_data  { ($($arg:tt)+) => { $crate::re_exports::log::warn!( target: "data", $($arg)+) } }
#[macro_export]
macro_rules! error_data { ($($arg:tt)+) => { $crate::re_exports::log::error!(target: "data", $($arg)+) } }

// data 域（数据平面）
#[macro_export]
macro_rules! trace_edata {
    ($event_id:expr, $($arg:tt)+) => {
        $crate::re_exports::log::trace!(target: "data", "[eid:{}] {}", $event_id, format_args!($($arg)+))
    }
}
#[macro_export]
macro_rules! debug_edata {
    ($event_id:expr, $($arg:tt)+) => {
        $crate::re_exports::log::debug!(target: "data", "[eid:{}] {}", $event_id, format_args!($($arg)+))
    }
}
#[macro_export]
macro_rules! info_edata {
    ($event_id:expr, $($arg:tt)+) => {
        $crate::re_exports::log::info!(target: "data", "[eid:{}] {}", $event_id, format_args!($($arg)+))
    }
}
#[macro_export]
macro_rules! warn_edata {
    ($event_id:expr, $($arg:tt)+) => {
        $crate::re_exports::log::warn!(target: "data", "[eid:{}] {}", $event_id, format_args!($($arg)+))
    }
}
#[macro_export]
macro_rules! error_edata {
    ($event_id:expr, $($arg:tt)+) => {
        $crate::re_exports::log::error!(target: "data", "[eid:{}] {}", $event_id, format_args!($($arg)+))
    }
}

// rule 域（策略/插件/接口）
#[macro_export]
macro_rules! trace_rule { ($($arg:tt)+) => { $crate::re_exports::log::trace!(target: "rule", $($arg)+) } }
#[macro_export]
macro_rules! debug_rule { ($($arg:tt)+) => { $crate::re_exports::log::debug!(target: "rule", $($arg)+) } }
#[macro_export]
macro_rules! info_rule  { ($($arg:tt)+) => { $crate::re_exports::log::info!( target: "rule", $($arg)+) } }
#[macro_export]
macro_rules! warn_rule  { ($($arg:tt)+) => { $crate::re_exports::log::warn!( target: "rule", $($arg)+) } }
#[macro_export]
macro_rules! error_rule { ($($arg:tt)+) => { $crate::re_exports::log::error!(target: "rule", $($arg)+) } }

// dfx 域（诊断 & 恢复）
#[macro_export]
macro_rules! trace_dfx { ($($arg:tt)+) => { $crate::re_exports::log::trace!(target: "dfx", $($arg)+) } }
#[macro_export]
macro_rules! debug_dfx { ($($arg:tt)+) => { $crate::re_exports::log::debug!(target: "dfx", $($arg)+) } }
#[macro_export]
macro_rules! info_dfx  { ($($arg:tt)+) => { $crate::re_exports::log::info!( target: "dfx", $($arg)+) } }
#[macro_export]
macro_rules! warn_dfx  { ($($arg:tt)+) => { $crate::re_exports::log::warn!( target: "dfx", $($arg)+) } }
#[macro_export]
macro_rules! error_dfx { ($($arg:tt)+) => { $crate::re_exports::log::error!(target: "dfx", $($arg)+) } }

// mtrc 域（指标 & 观测）
#[macro_export]
macro_rules! trace_mtrc { ($($arg:tt)+) => { $crate::re_exports::log::trace!(target: "mtrc", $($arg)+) } }
#[macro_export]
macro_rules! debug_mtrc { ($($arg:tt)+) => { $crate::re_exports::log::debug!(target: "mtrc", $($arg)+) } }
#[macro_export]
macro_rules! info_mtrc  { ($($arg:tt)+) => { $crate::re_exports::log::info!( target: "mtrc", $($arg)+) } }
#[macro_export]
macro_rules! warn_mtrc  { ($($arg:tt)+) => { $crate::re_exports::log::warn!( target: "mtrc", $($arg)+) } }
#[macro_export]
macro_rules! error_mtrc { ($($arg:tt)+) => { $crate::re_exports::log::error!(target: "mtrc", $($arg)+) } }

#[macro_export]
macro_rules! println_mtrc {
    ($($arg:tt)+) => {
        let val = std::env::var($crate::conf::PRINT_STAT).unwrap_or("false".to_string());
        if val.eq("true") {
            println!("{}", format_args!($($arg)+));
        }
    }
}

// kdb 域（知识库）
#[macro_export]
macro_rules! trace_kdb { ($($arg:tt)+) => { $crate::re_exports::log::trace!(target: "kdb", $($arg)+) } }
#[macro_export]
macro_rules! debug_kdb { ($($arg:tt)+) => { $crate::re_exports::log::debug!(target: "kdb", $($arg)+) } }
#[macro_export]
macro_rules! info_kdb  { ($($arg:tt)+) => { $crate::re_exports::log::info!( target: "kdb", $($arg)+) } }
#[macro_export]
macro_rules! warn_kdb  { ($($arg:tt)+) => { $crate::re_exports::log::warn!( target: "kdb", $($arg)+) } }
#[macro_export]
macro_rules! error_kdb { ($($arg:tt)+) => { $crate::re_exports::log::error!(target: "kdb", $($arg)+) } }