fix: add separate config option for redis events replica url (#590)
This commit is contained in:
@@ -218,7 +218,13 @@ async fn listener(
|
|||||||
kill_signal_r: async_channel::Receiver<()>,
|
kill_signal_r: async_channel::Receiver<()>,
|
||||||
write: &Mutex<WsWriter>,
|
write: &Mutex<WsWriter>,
|
||||||
) {
|
) {
|
||||||
let redis_config = RedisConfig::from_url(&REDIS_URI).unwrap();
|
let stoat_config = revolt_config::config().await;
|
||||||
|
let url = stoat_config
|
||||||
|
.database
|
||||||
|
.redis_pubsub
|
||||||
|
.unwrap_or(REDIS_URI.to_string());
|
||||||
|
|
||||||
|
let redis_config = RedisConfig::from_url(&url).unwrap();
|
||||||
let subscriber = match report_internal_error!(
|
let subscriber = match report_internal_error!(
|
||||||
fred::types::Builder::from_config(redis_config).build_subscriber_client()
|
fred::types::Builder::from_config(redis_config).build_subscriber_client()
|
||||||
) {
|
) {
|
||||||
|
|||||||
@@ -117,6 +117,7 @@ static CONFIG_BUILDER: Lazy<RwLock<Config>> = Lazy::new(|| {
|
|||||||
pub struct Database {
|
pub struct Database {
|
||||||
pub mongodb: String,
|
pub mongodb: String,
|
||||||
pub redis: String,
|
pub redis: String,
|
||||||
|
pub redis_pubsub: Option<String>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Deserialize, Debug, Clone)]
|
#[derive(Deserialize, Debug, Clone)]
|
||||||
|
|||||||
Reference in New Issue
Block a user