aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/https.rs8
-rw-r--r--src/main.rs10
-rw-r--r--src/reverse_proxy.rs2
3 files changed, 10 insertions, 10 deletions
diff --git a/src/https.rs b/src/https.rs
index ce9c61f..6e83c9e 100644
--- a/src/https.rs
+++ b/src/https.rs
@@ -213,7 +213,7 @@ async fn select_target_and_proxy(
let host = if let Some(auth) = req.uri().authority() {
auth.as_str()
} else {
- match req.headers().get("host").map(|x| x.to_str().ok()).flatten() {
+ match req.headers().get("host").and_then(|x| x.to_str().ok()) {
Some(host) => host,
None => {
return Response::builder()
@@ -268,7 +268,7 @@ async fn select_target_and_proxy(
debug!("{}{} -> {}", host, path, proxy_to);
trace!("Request: {:?}", req);
- let response = match do_proxy(&https_config, remote_addr, req, proxy_to).await {
+ let response = match do_proxy(https_config, remote_addr, req, proxy_to).await {
Ok(resp) => resp,
Err(e) => Response::builder()
.status(StatusCode::BAD_GATEWAY)
@@ -279,7 +279,7 @@ async fn select_target_and_proxy(
proxy_to.calls_in_progress.fetch_sub(1, Ordering::SeqCst);
metrics
.request_proxy_duration
- .record(received_time.elapsed().as_secs_f64(), &tags);
+ .record(received_time.elapsed().as_secs_f64(), tags);
trace!("Final response: {:?}", response);
info!("{} {} {}", method, response.status().as_u16(), uri);
@@ -323,7 +323,7 @@ async fn do_proxy(
}
if https_config.enable_compression {
- response = try_compress(response, method, accept_encoding, &https_config).await?
+ response = try_compress(response, method, accept_encoding, https_config).await?
};
Ok(response)
diff --git a/src/main.rs b/src/main.rs
index 34c80f8..79c4a9b 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -192,10 +192,10 @@ async fn main() {
let dump_task = tokio::spawn(dump_config_on_change(rx_proxy_config, exit_signal.clone()));
- let _ = metrics_task.await.expect("Tokio task await failure");
- let _ = http_task.await.expect("Tokio task await failure");
- let _ = https_task.await.expect("Tokio task await failure");
- let _ = dump_task.await.expect("Tokio task await failure");
+ metrics_task.await.expect("Tokio task await failure");
+ http_task.await.expect("Tokio task await failure");
+ https_task.await.expect("Tokio task await failure");
+ dump_task.await.expect("Tokio task await failure");
}
async fn dump_config_on_change(
@@ -205,7 +205,7 @@ async fn dump_config_on_change(
while !*must_exit.borrow() {
select!(
c = rx_proxy_config.changed() => {
- if !c.is_ok() {
+ if c.is_err() {
break;
}
}
diff --git a/src/reverse_proxy.rs b/src/reverse_proxy.rs
index 74c43e3..258862b 100644
--- a/src/reverse_proxy.rs
+++ b/src/reverse_proxy.rs
@@ -178,7 +178,7 @@ async fn create_proxied_response<B: std::default::Default + Send + Sync + 'stati
*new_res.headers_mut().unwrap() = new_headers;
Ok(new_res.body(B::default())?)
} else {
- return Err(anyhow!("Switching protocols but not an upgrade request"));
+ Err(anyhow!("Switching protocols but not an upgrade request"))
}
} else {
*response.headers_mut() = new_headers;