Data points are now logged according to their level, instead of always debug! (#5906)
Note that Counters remain at debug! to avoid excessive default logging
This commit is contained in:
parent
84c8a5bbec
commit
a6479eb6e9
|
@ -206,7 +206,7 @@ impl MetricsAgent {
|
||||||
barrier.wait();
|
barrier.wait();
|
||||||
}
|
}
|
||||||
MetricsCommand::Submit(point, level) => {
|
MetricsCommand::Submit(point, level) => {
|
||||||
debug!("run: submit {:?}", point);
|
log!(level, "{:?}", point);
|
||||||
let (_, _, points) = points_map.entry(level).or_insert((
|
let (_, _, points) = points_map.entry(level).or_insert((
|
||||||
last_write_time,
|
last_write_time,
|
||||||
HashMap::new(),
|
HashMap::new(),
|
||||||
|
@ -215,7 +215,7 @@ impl MetricsAgent {
|
||||||
points.push(point);
|
points.push(point);
|
||||||
}
|
}
|
||||||
MetricsCommand::SubmitCounter(counter, level, bucket) => {
|
MetricsCommand::SubmitCounter(counter, level, bucket) => {
|
||||||
debug!("run: submit counter {:?}", counter);
|
debug!("{:?}", counter);
|
||||||
let (_, counters, _) = points_map.entry(level).or_insert((
|
let (_, counters, _) = points_map.entry(level).or_insert((
|
||||||
last_write_time,
|
last_write_time,
|
||||||
HashMap::new(),
|
HashMap::new(),
|
||||||
|
@ -276,16 +276,14 @@ impl MetricsAgent {
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn submit(&self, point: DataPoint, level: log::Level) {
|
pub fn submit(&self, point: DataPoint, level: log::Level) {
|
||||||
debug!("Submitting data point: {:?}", point);
|
|
||||||
self.sender
|
self.sender
|
||||||
.send(MetricsCommand::Submit(point, level))
|
.send(MetricsCommand::Submit(point, level))
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn submit_counter(&self, point: CounterPoint, level: log::Level, bucket: u64) {
|
pub fn submit_counter(&self, counter: CounterPoint, level: log::Level, bucket: u64) {
|
||||||
debug!("Submitting counter point: {:?}", point);
|
|
||||||
self.sender
|
self.sender
|
||||||
.send(MetricsCommand::SubmitCounter(point, level, bucket))
|
.send(MetricsCommand::SubmitCounter(counter, level, bucket))
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue