adding balances
This commit is contained in:
parent
992860a46d
commit
32156e981d
@ -725,6 +725,8 @@ impl BufferedRpcQueryStats {
|
|||||||
// Read the latest balance ...
|
// Read the latest balance ...
|
||||||
let remaining = self.latest_balance.read().remaining();
|
let remaining = self.latest_balance.read().remaining();
|
||||||
|
|
||||||
|
trace!("Remaining balance for influx is {:?}", remaining);
|
||||||
|
|
||||||
builder = builder
|
builder = builder
|
||||||
.tag("archive_needed", key.archive_needed.to_string())
|
.tag("archive_needed", key.archive_needed.to_string())
|
||||||
.tag("error_response", key.error_response.to_string())
|
.tag("error_response", key.error_response.to_string())
|
||||||
@ -744,13 +746,17 @@ impl BufferedRpcQueryStats {
|
|||||||
)
|
)
|
||||||
.field(
|
.field(
|
||||||
"balance",
|
"balance",
|
||||||
remaining.to_f64().context("balance is really (too) large")?,
|
remaining
|
||||||
|
.to_f64()
|
||||||
|
.context("balance is really (too) large")?,
|
||||||
);
|
);
|
||||||
|
|
||||||
builder = builder.timestamp(key.response_timestamp);
|
builder = builder.timestamp(key.response_timestamp);
|
||||||
|
|
||||||
let point = builder.build()?;
|
let point = builder.build()?;
|
||||||
|
|
||||||
|
trace!("Datapoint saving to Influx is {:?}", point);
|
||||||
|
|
||||||
Ok(point)
|
Ok(point)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user