rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-17 10:22:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix the with

Browse Source
This commit is contained in:
Anton Chaporgin
2024-07-19 16:43:29 +03:00
parent 8646fc8361
commit a6e67eb13e
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
proxy/src/bin/proxy.rs
View File

@@ -322,16 +322,16 @@ async fn main() -> anyhow::Result<()> {
),
aws_credentials_provider,
));
let regional_redis_client = match args.redis_auth_type.as_str() {
"plain" => {
match args.redis_notifications {
let regional_redis_client = match (args.redis_auth_type.as_str(), &args.redis_notifications) {
("plain", redis_url) => {
match redis_url {
None => {
bail!("plain auth requires redis_notifications to be set");
},
Some(url) => Some(ConnectionWithCredentialsProvider::new_with_static_credentials(url)),
Some(url) => Some(ConnectionWithCredentialsProvider::new_with_static_credentials(url.to_string())),
}
}
"irsa" => {
("irsa", _) => {
match (&args.redis_host, args.redis_port) {
(Some(host), Some(port)) => Some(
ConnectionWithCredentialsProvider::new_with_credentials_provider(
@@ -353,7 +353,7 @@ async fn main() -> anyhow::Result<()> {
}
};
let redis_notifications_client = if let Some(url) = &args.redis_notifications {
let redis_notifications_client = if let Some(url) = args.redis_notifications {
Some(ConnectionWithCredentialsProvider::new_with_static_credentials(url.to_string()))
} else {
regional_redis_client.clone()