30 second flushes for db too
This commit is contained in:
parent
0a3698de0f
commit
620f2d9d00
@ -329,7 +329,7 @@ impl Web3ProxyApp {
|
|||||||
let stat_sender = if let Some(spawned_stat_buffer) = StatBuffer::try_spawn(
|
let stat_sender = if let Some(spawned_stat_buffer) = StatBuffer::try_spawn(
|
||||||
BILLING_PERIOD_SECONDS,
|
BILLING_PERIOD_SECONDS,
|
||||||
top_config.app.chain_id,
|
top_config.app.chain_id,
|
||||||
60,
|
30,
|
||||||
top_config.app.influxdb_bucket.clone(),
|
top_config.app.influxdb_bucket.clone(),
|
||||||
influxdb_client.clone(),
|
influxdb_client.clone(),
|
||||||
rpc_secret_key_cache.clone(),
|
rpc_secret_key_cache.clone(),
|
||||||
|
@ -441,7 +441,7 @@ impl StatBuffer {
|
|||||||
if count > 0 {
|
if count > 0 {
|
||||||
// TODO: put max_batch_size in config?
|
// TODO: put max_batch_size in config?
|
||||||
// TODO: i think the real limit is the byte size of the http request. so, a simple line count won't work very well
|
// TODO: i think the real limit is the byte size of the http request. so, a simple line count won't work very well
|
||||||
let max_batch_size = 100;
|
let max_batch_size = 1000;
|
||||||
|
|
||||||
let mut num_left = count;
|
let mut num_left = count;
|
||||||
|
|
||||||
|
@ -499,7 +499,7 @@ async fn test_referral_bonus_concurrent_referrer_only() {
|
|||||||
let number_requests = 100;
|
let number_requests = 100;
|
||||||
// Spin up concurrent requests ...
|
// Spin up concurrent requests ...
|
||||||
let mut handles = Vec::with_capacity(number_requests);
|
let mut handles = Vec::with_capacity(number_requests);
|
||||||
for _ in 1..number_requests {
|
for _ in 0..number_requests {
|
||||||
let url = x.proxy_provider.url().clone();
|
let url = x.proxy_provider.url().clone();
|
||||||
let secret_key = rpc_keys.secret_key;
|
let secret_key = rpc_keys.secret_key;
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user