+1 -1

osprey_coordinator/etcd_config_derive/src/disconfigs.rs

reviewed

··· 29 29 .meta; 30 30 31 31 let config_name = ConfigName::from_meta(config_name_meta)?.name.value(); 32 32 - let key_root = format!("/discord_configs/{config_name}/v1/"); 32 32 + let key_root = format!("/osprey_configs/{config_name}/v1/"); 33 33 // Inside Disconfig struct, there should be one and only one ArcSwap field. 34 34 let fields = self.fields(); 35 35 let mut arc_swap_field_count = 0;

+2 -2

osprey_coordinator/src/gcloud/pubsub.rs

reviewed

··· 582 582 } 583 583 584 584 define_metrics!(PubsubStats, [ 585 585 - publish_failed => DynamicCounter("discord_gcloud.pubsub.publish.failed", [project, topic]), 586 586 - publish_sends => DynamicCounter("discord_gcloud.pubsub.publish.sends", [project, topic]), 585 585 + publish_failed => DynamicCounter("osprey_gcloud.pubsub.publish.failed", [project, topic]), 586 586 + publish_sends => DynamicCounter("osprey_gcloud.pubsub.publish.sends", [project, topic]), 587 587 ]);

+1 -1

osprey_coordinator/src/pigeon/health.rs

reviewed

··· 9 9 HealthCheckResponse, 10 10 }; 11 11 12 12 - const HEALTH_CHECK_ALL_PSEUDO_SERVICE: &str = "discord.v1.HealthCheckAll"; 12 12 + const HEALTH_CHECK_ALL_PSEUDO_SERVICE: &str = "osprey.v1.HealthCheckAll"; 13 13 14 14 pub trait HealthChecker: Send + Sync + 'static { 15 15 fn is_healthy(&self) -> bool;

+4 -6

osprey_coordinator/src/pubsub.rs

reviewed

··· 205 205 metrics: Arc<OspreyCoordinatorMetrics>, 206 206 ) -> Result<()> { 207 207 let subscriber_client = create_pubsub_subscription_client().await; 208 208 - let subscription_name = if std::env::var("PUBSUB_EMULATOR_HOST").is_ok() { 209 209 - PubSubSubscription::new("discord-dev", "rules-sink") 210 210 - } else { 211 211 - let project_id = std::env::var("PUBSUB_SUBSCRIPTION_PROJECT_ID") 212 212 - .unwrap_or("discord-anti-abuse-prd".to_string()); 208 208 + let subscription_name = { 209 209 + let project_id = 210 210 + std::env::var("PUBSUB_SUBSCRIPTION_PROJECT_ID").unwrap_or("osprey-dev".to_string()); 213 211 214 212 let subscription_id = std::env::var("PUBSUB_SUBSCRIPTION_ID") 215 215 - .unwrap_or("osprey-coordinator-test".to_string()); 213 213 + .unwrap_or("osprey-coordinator-actions".to_string()); 216 214 217 215 PubSubSubscription::new(project_id, subscription_id) 218 216 };