remove some instruments
This commit is contained in:
parent
ce3fbca7b6
commit
97677cd746
|
@ -8,7 +8,7 @@
|
||||||
|
|
||||||
use migration::sea_orm::prelude::Decimal;
|
use migration::sea_orm::prelude::Decimal;
|
||||||
use std::{ops::Add, str::FromStr};
|
use std::{ops::Add, str::FromStr};
|
||||||
use tracing::{instrument, trace, warn};
|
use tracing::{trace, warn};
|
||||||
|
|
||||||
/// TODO: i don't like how we use this inside the config and also have it available publicly. we should only getting this value from the config
|
/// TODO: i don't like how we use this inside the config and also have it available publicly. we should only getting this value from the config
|
||||||
pub fn default_usd_per_cu(chain_id: u64) -> Decimal {
|
pub fn default_usd_per_cu(chain_id: u64) -> Decimal {
|
||||||
|
@ -42,7 +42,6 @@ where
|
||||||
|
|
||||||
impl ComputeUnit {
|
impl ComputeUnit {
|
||||||
/// costs can vary widely depending on method and chain
|
/// costs can vary widely depending on method and chain
|
||||||
#[instrument(level = "trace")]
|
|
||||||
pub fn new(method: &str, chain_id: u64, response_bytes: u64) -> Self {
|
pub fn new(method: &str, chain_id: u64, response_bytes: u64) -> Self {
|
||||||
// TODO: this works, but this is fragile. think of a better way to check the method is a subscription
|
// TODO: this works, but this is fragile. think of a better way to check the method is a subscription
|
||||||
if method.ends_with(')') {
|
if method.ends_with(')') {
|
||||||
|
@ -180,7 +179,6 @@ impl ComputeUnit {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// notifications and subscription responses cost per-byte
|
/// notifications and subscription responses cost per-byte
|
||||||
#[instrument(level = "trace")]
|
|
||||||
pub fn variable_price<D: Into<Decimal> + std::fmt::Debug>(
|
pub fn variable_price<D: Into<Decimal> + std::fmt::Debug>(
|
||||||
chain_id: u64,
|
chain_id: u64,
|
||||||
method: &str,
|
method: &str,
|
||||||
|
@ -199,7 +197,6 @@ impl ComputeUnit {
|
||||||
/// Compute cost per request
|
/// Compute cost per request
|
||||||
/// All methods cost the same
|
/// All methods cost the same
|
||||||
/// The number of bytes are based on input, and output bytes
|
/// The number of bytes are based on input, and output bytes
|
||||||
#[instrument(level = "trace")]
|
|
||||||
pub fn cost(
|
pub fn cost(
|
||||||
&self,
|
&self,
|
||||||
archive_request: bool,
|
archive_request: bool,
|
||||||
|
|
|
@ -23,7 +23,7 @@ use std::time::Duration;
|
||||||
use tokio::select;
|
use tokio::select;
|
||||||
use tokio::task::yield_now;
|
use tokio::task::yield_now;
|
||||||
use tokio::time::{sleep_until, Instant};
|
use tokio::time::{sleep_until, Instant};
|
||||||
use tracing::{debug, enabled, error, info, instrument, trace, warn, Level};
|
use tracing::{debug, enabled, error, info, trace, warn, Level};
|
||||||
|
|
||||||
#[derive(Constructor, Clone, Copy, Debug, Default, Eq, PartialEq, Serialize)]
|
#[derive(Constructor, Clone, Copy, Debug, Default, Eq, PartialEq, Serialize)]
|
||||||
pub struct RpcRanking {
|
pub struct RpcRanking {
|
||||||
|
@ -874,7 +874,6 @@ fn best_rpc<'a>(rpc_a: &'a Arc<Web3Rpc>, rpc_b: &'a Arc<Web3Rpc>) -> &'a Arc<Web
|
||||||
*/
|
*/
|
||||||
|
|
||||||
impl RpcsForRequest {
|
impl RpcsForRequest {
|
||||||
#[instrument]
|
|
||||||
pub fn to_stream(self) -> impl Stream<Item = OpenRequestHandle> {
|
pub fn to_stream(self) -> impl Stream<Item = OpenRequestHandle> {
|
||||||
stream! {
|
stream! {
|
||||||
trace!("entered stream");
|
trace!("entered stream");
|
||||||
|
|
Loading…
Reference in New Issue