logos-co
/
nomos-simulations
mirror of https://github.com/logos-co/nomos-simulations.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

enrich monitors log

This commit is contained in:
Youngjoon Lee 2024-12-06 17:04:37 +09:00
parent 6ca609acd9
commit 1662a659e9
No known key found for this signature in database
GPG Key ID: 680B4E130CB5030E
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
simlib/blendnet-sims/src/node/mix/mod.rs
View File

@ -315,13 +315,15 @@ impl MixNode {
tracing::info!("Emission: {}", serde_json::to_string(log).unwrap());
}
fn log_monitor(&self, effective_messages_series: &Series) {
fn log_monitors(&self, effective_messages_series: &Series) {
if effective_messages_series.is_empty() {
return;
}
let log = SeriesLog {
series_type: "EffectiveMessages".to_string(),
let log = MonitorsLog {
node_id: self.id.index(),
message_type: "EffectiveMessage".to_string(),
num_conns: effective_messages_series.len(),
min: effective_messages_series.min().unwrap().unwrap(),
avg: effective_messages_series.mean().unwrap(),
median: effective_messages_series.median().unwrap(),
@ -378,7 +380,7 @@ impl Node for MixNode {
.values()
.map(|monitor| monitor.effective_messages as u64),
);
self.log_monitor(&effective_messages_series);
self.log_monitors(&effective_messages_series);
}
// Handle incoming messages
@ -459,8 +461,10 @@ struct EmissionLog {
}
#[derive(Debug, Serialize, Deserialize)]
struct SeriesLog {
series_type: String,
struct MonitorsLog {
node_id: usize,
message_type: String,
num_conns: usize,
min: u64,
avg: f64,
median: f64,