refactor: better main function

.github/workflows/ci.yaml

@@ -33,6 +33,8 @@ jobs:
 
       - name: Install protoc
         uses: arduino/setup-protoc@v2
+        with:
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
 
       - name: Set up Rust cache
         uses: Swatinem/rust-cache@v2

hello-tracing-backend/src/main.rs

@@ -1,3 +1,5 @@
+#![feature(result_option_inspect)]
+
 mod api;
 
 use anyhow::{Context, Result};
@@ -11,33 +13,26 @@ use std::panic;
 use tracing::{error, info};
 
 #[tokio::main]
-async fn main() {
+async fn main() -> Result<()> {
     // Load configuration first, because needed for tracing initialization.
-    let config = match Config::load().context("load configuration") {
-        Ok(config) => config,
-        Err(error) => {
-            log_error(error);
-            return;
-        }
-    };
+    let config = Config::load()
+        .context("load configuration")
+        .inspect_err(log_error)?;
 
     // If tracing initialization fails, nevertheless emit a structured log event.
-    if let Err(error) = init_tracing(config.tracing.clone()) {
-        log_error(error);
-        return;
-    }
+    init_tracing(config.tracing.clone()).inspect_err(log_error)?;
 
     // Replace the default panic hook with one that uses structured logging at ERROR level.
     panic::set_hook(Box::new(|panic| error!(%panic, "process panicked")));
 
     // Run and log any error.
-    if let Err(error) = run(config).await {
+    run(config).await.inspect_err(|error| {
         error!(
             error = format!("{error:#}"),
             backtrace = %error.backtrace(),
             "process exited with ERROR"
         );
-    };
+    })
 }
 
 #[derive(Debug, Deserialize)]

hello-tracing-common/src/lib.rs

@@ -5,7 +5,7 @@ use time::{format_description::well_known::Rfc3339, OffsetDateTime};
 pub mod otel;
 pub mod tracing;
 
-pub fn log_error(error: impl Display) {
+pub fn log_error(error: &impl Display) {
     let now = OffsetDateTime::now_utc().format(&Rfc3339).unwrap();
     let error = serde_json::to_string(&json!({
         "timestamp": now,

hello-tracing-common/src/tracing.rs

@@ -6,6 +6,7 @@ use opentelemetry::{
 };
 use opentelemetry_otlp::WithExportConfig;
 use serde::Deserialize;
+
 use tracing::{error, Subscriber};
 use tracing_subscriber::{
     fmt, layer::SubscriberExt, registry::LookupSpan, util::SubscriberInitExt, EnvFilter, Layer,

hello-tracing-gateway/src/main.rs

@@ -1,3 +1,5 @@
+#![feature(result_option_inspect)]
+
 mod api;
 mod backend;
 
@@ -13,33 +15,26 @@ use std::panic;
 use tracing::{error, info};
 
 #[tokio::main]
-async fn main() {
+async fn main() -> Result<()> {
     // Load configuration first, because needed for tracing initialization.
-    let config = match Config::load().context("load configuration") {
-        Ok(config) => config,
-        Err(error) => {
-            log_error(error);
-            return;
-        }
-    };
+    let config = Config::load()
+        .context("load configuration")
+        .inspect_err(log_error)?;
 
     // If tracing initialization fails, nevertheless emit a structured log event.
-    if let Err(error) = init_tracing(config.tracing.clone()) {
-        log_error(error);
-        return;
-    }
+    init_tracing(config.tracing.clone()).inspect_err(log_error)?;
 
     // Replace the default panic hook with one that uses structured logging at ERROR level.
     panic::set_hook(Box::new(|panic| error!(%panic, "process panicked")));
 
     // Run and log any error.
-    if let Err(error) = run(config).await {
+    run(config).await.inspect_err(|error| {
         error!(
             error = format!("{error:#}"),
             backtrace = %error.backtrace(),
             "process exited with ERROR"
         );
-    };
+    })
 }
 
 #[derive(Debug, Deserialize)]

rust-toolchain.toml

@@ -1,2 +1,2 @@
 [toolchain]
-channel = "stable"
+channel = "nightly"