Throttle BatchSpanProcessor.Flush.ExportError otel events

Author: khvzak

Cargo.lock

@@ -38,7 +38,6 @@ opentelemetry-prometheus = "0.27"
 opentelemetry-semantic-conventions = "0.27"
 opentelemetry-zipkin = { version = "0.27", default-features = false }
 opentelemetry_sdk = { version = "0.27", features = ["rt-tokio-current-thread"] }
-opentelemetry-appender-tracing = "0.27.0"
 ouroboros = "0.18"
 parking_lot = "0.12"
 percent-encoding = "2.2"

casper-server/Cargo.toml

@@ -42,6 +42,9 @@ async fn main_inner(args: Args) -> anyhow::Result<()> {
         env::set_var("OTEL_SERVICE_NAME", service_name);
     }
 
+    // Init logging subsystem
+    crate::logs::init(&config);
+
     // Init tracing subsystem
     crate::trace::init(&config);
 
@@ -145,6 +148,7 @@ mod config;
 mod context;
 mod handler;
 mod http;
+mod logs;
 mod lua;
 mod middleware;
 mod storage;

casper-server/src/main.rs

@@ -7,25 +7,10 @@ use ntex::time::Millis;
 use opentelemetry_http::{HttpClient, HttpError, Request, Response};
 use opentelemetry_sdk::trace::{self, RandomIdGenerator, Sampler};
 use tokio::sync::{mpsc, oneshot};
-use tracing_subscriber::layer::SubscriberExt;
-use tracing_subscriber::util::SubscriberInitExt as _;
-use tracing_subscriber::EnvFilter;
 
 use crate::config::Config;
 
 pub fn init(config: &Config) {
-    init_opentelemetry(config);
-
-    let env_filter = EnvFilter::try_from_default_env().unwrap_or(EnvFilter::new("info"));
-    let fmt_layer = tracing_subscriber::fmt::layer();
-
-    tracing_subscriber::registry()
-        .with(env_filter)
-        .with(fmt_layer)
-        .init();
-}
-
-fn init_opentelemetry(config: &Config) {
     let tracing_conf = match config.tracing {
         Some(ref tracing_conf) if tracing_conf.enabled => tracing_conf,
         _ => return,