cerc-io/lighthouse
10
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Add extra metrics for prom

Browse Source
This commit is contained in:
Paul Hauner 2019-05-28 16:11:16 +10:00
parent 3e73a008eb
commit e756a0aaa4
No known key found for this signature in database
GPG Key ID: 5E2CFF9B75FA63DF
1 changed files with 22 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
beacon_node/http_server/src/metrics.rs
View File

@ -29,16 +29,22 @@ fn handle_metrics<T: BeaconChainTypes + 'static>(req: &mut Request) -> IronResul
let r = Registry::new(); let r = Registry::new();
let present_slot = if let Ok(Some(slot)) = beacon_chain.slot_clock.present_slot() { let present_slot = beacon_chain
slot .slot_clock
} else { .present_slot()
Slot::new(0) .unwrap_or_else(|_| None)
}; .unwrap_or_else(|| Slot::new(0));
register_and_set_slot( register_and_set_slot(&r, "present_slot", "slock_clock_reading", present_slot);
let best_slot = beacon_chain.head().beacon_block.slot;
register_and_set_slot(&r, "best_slot", "slot_of_block_at_head_of_chain", best_slot);
let validator_count = beacon_chain.head().beacon_state.validator_registry.len();
register_and_set(
&r, &r,
"present_slot", "validator_count",
"direct_slock_clock_reading", "total_number_of_validators",
present_slot, validator_count as i64,
); );
// Gather the metrics. // Gather the metrics.
@ -52,6 +58,13 @@ fn handle_metrics<T: BeaconChainTypes + 'static>(req: &mut Request) -> IronResul
Ok(Response::with((Status::Ok, prom_string))) Ok(Response::with((Status::Ok, prom_string)))
} }
fn register_and_set(registry: &Registry, name: &str, help: &str, value: i64) {
let counter_opts = Opts::new(name, help);
let counter = IntCounter::with_opts(counter_opts).unwrap();
registry.register(Box::new(counter.clone())).unwrap();
counter.inc_by(value);
}
fn register_and_set_slot(registry: &Registry, name: &str, help: &str, slot: Slot) { fn register_and_set_slot(registry: &Registry, name: &str, help: &str, slot: Slot) {
let counter_opts = Opts::new(name, help); let counter_opts = Opts::new(name, help);
let counter = IntCounter::with_opts(counter_opts).unwrap(); let counter = IntCounter::with_opts(counter_opts).unwrap();