address comments

Author: cctdaniel

config/config.sample.pythnet.toml

@@ -70,12 +70,3 @@ exporter.maximum_compute_unit_price_micro_lamports = 100000
 # Note that this doesn't affect the rate at which transactions are published:
 # this is soley a backwards-compatibility API feature.
 notify_price_sched_interval_duration = "400ms"
-
-# Configuration for OpenTelemetry
-[opentelemetry]
-
-# Timeout in seconds for the OpenTelemetry exporter
-exporter_timeout_secs = 3
-
-# Endpoint URL for the OpenTelemetry exporter
-exporter_endpoint = "http://127.0.0.1:4317"

config/config.sample.pythtest.toml

@@ -60,12 +60,3 @@ exporter.compute_unit_price_micro_lamports = 1000
 # Note that this doesn't affect the rate at which transactions are published:
 # this is soley a backwards-compatibility API feature.
 notify_price_sched_interval_duration = "400ms"
-
-# Configuration for OpenTelemetry
-[opentelemetry]
-
-# Timeout in seconds for the OpenTelemetry exporter
-exporter_timeout_secs = 3
-
-# Endpoint URL for the OpenTelemetry exporter
-exporter_endpoint = "http://127.0.0.1:4317"

src/bin/agent.rs

@@ -16,7 +16,10 @@ use {
         path::PathBuf,
         time::Duration,
     },
-    tracing_subscriber::prelude::*,
+    tracing_subscriber::{
+        prelude::*,
+        EnvFilter,
+    },
 };
 
 #[derive(Parser, Debug)]
@@ -45,6 +48,8 @@ async fn main() -> Result<()> {
     // Parse config early for logging channel capacity
     let config = Config::new(args.config).context("Could not parse config")?;
 
+    let env_filter = EnvFilter::from_default_env();
+
     // Initialize a Tracing Subscriber
     let fmt_layer = tracing_subscriber::fmt::layer()
         .with_file(false)
@@ -73,7 +78,9 @@ async fn main() -> Result<()> {
     // Set up the telemetry layer
     let telemetry = tracing_opentelemetry::layer().with_tracer(tracer);
 
-    let registry = tracing_subscriber::registry().with(telemetry);
+    let registry = tracing_subscriber::registry()
+        .with(telemetry)
+        .with(env_filter);
 
     // Use the compact formatter if we're in a terminal, otherwise use the JSON formatter.
     if std::io::stderr().is_terminal() {