facebook/sapling
1
1
Fork 0
mirror of https://github.com/facebook/sapling.git synced 2024-10-11 09:17:30 +03:00
Code Issues Projects Releases Wiki Activity

blobstore_healer: fix how replication lag is monitored

Browse Source 
Summary: We were monitoring the wrong lag so far.

Reviewed By: farnz

Differential Revision: D22356455

fbshipit-source-id: abe41a4154c2a8d53befed4760e2e9544797c845
This commit is contained in:
Kostia Balytskyi 2020-07-02 06:16:56 -07:00 committed by Facebook GitHub Bot
parent f6d06a266a
commit b134a2f5bb
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
eden/mononoke/cmds/blobstore_healer/main.rs
View File

@ -28,7 +28,7 @@ use fbinit::FacebookInit;
use futures::{compat::Future01CompatExt, future};
use healer::Healer;
use lazy_static::lazy_static;
use metaconfig_types::{BlobConfig, LocalDatabaseConfig, MetadataDatabaseConfig, StorageConfig};
use metaconfig_types::{BlobConfig, DatabaseConfig, LocalDatabaseConfig, StorageConfig};
use mononoke_types::DateTime;
use slog::{info, o, warn};
use sql::Connection;
@ -176,13 +176,13 @@ async fn maybe_schedule_healer_for_storage(
.into_iter()
.collect::<HashMap<_, _>>();
let regional_conns = match storage_config.metadata {
MetadataDatabaseConfig::Local(LocalDatabaseConfig { path }) => {
let regional_conns = match queue_db {
DatabaseConfig::Local(LocalDatabaseConfig { path }) => {
let c = open_sqlite_path(path.join("sqlite_dbs"), readonly_storage.0)?;
vec![("sqlite_region".to_string(), Connection::with_sqlite(c))]
}
MetadataDatabaseConfig::Remote(remote) => {
let db_address = remote.primary.db_address;
DatabaseConfig::Remote(remote) => {
let db_address = remote.db_address;
let regions = ConfigStore::configerator(fb, None, None, Duration::from_secs(5))?
.get_config_handle::<Vec<String>>(CONFIGERATOR_REGIONS_CONFIG.to_owned())?
.get();