diff options
| author | networkException <git@nwex.de> | 2023-09-29 18:41:00 +0200 |
|---|---|---|
| committer | networkException <git@nwex.de> | 2023-09-29 18:57:44 +0200 |
| commit | 8ec6a53b35e5bb742640a77ff282f2474c63af54 (patch) | |
| tree | 4b6a82342cd9ce665d933dc243be7e34ad608f32 /src/garage | |
| parent | 7353038a64cc53cc01c4ec7f21671d3443177707 (diff) | |
| download | garage-8ec6a53b35e5bb742640a77ff282f2474c63af54.tar.gz garage-8ec6a53b35e5bb742640a77ff282f2474c63af54.zip | |
everywhere: support unix sockets when binding in various places
this patch implements binding to paths as a unix socket for generic
server and web server.
Diffstat (limited to 'src/garage')
| -rw-r--r-- | src/garage/server.rs | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/garage/server.rs b/src/garage/server.rs index 472616c7..3ad10b72 100644 --- a/src/garage/server.rs +++ b/src/garage/server.rs @@ -79,7 +79,7 @@ pub async fn run_server(config_file: PathBuf, secrets: Secrets) -> Result<(), Er "S3 API", tokio::spawn(S3ApiServer::run( garage.clone(), - *s3_bind_addr, + s3_bind_addr.clone(), config.s3_api.s3_region.clone(), wait_from(watch_cancel.clone()), )), @@ -94,7 +94,7 @@ pub async fn run_server(config_file: PathBuf, secrets: Secrets) -> Result<(), Er "K2V API", tokio::spawn(K2VApiServer::run( garage.clone(), - config.k2v_api.as_ref().unwrap().api_bind_addr, + config.k2v_api.as_ref().unwrap().api_bind_addr.clone(), config.s3_api.s3_region.clone(), wait_from(watch_cancel.clone()), )), @@ -110,7 +110,7 @@ pub async fn run_server(config_file: PathBuf, secrets: Secrets) -> Result<(), Er "Web", tokio::spawn(WebServer::run( garage.clone(), - web_config.bind_addr, + web_config.bind_addr.clone(), web_config.root_domain.clone(), wait_from(watch_cancel.clone()), )), @@ -121,7 +121,9 @@ pub async fn run_server(config_file: PathBuf, secrets: Secrets) -> Result<(), Er info!("Launching Admin API server..."); servers.push(( "Admin", - tokio::spawn(admin_server.run(*admin_bind_addr, wait_from(watch_cancel.clone()))), + tokio::spawn( + admin_server.run(admin_bind_addr.clone(), wait_from(watch_cancel.clone())), + ), )); } |