tokio based simple

Author: cijothomas

opentelemetry-otlp/tests/integration_test/tests/logs.rs

@@ -123,6 +123,49 @@ mod logtests {
         Ok(())
     }
 
+    #[tokio::test(flavor = "multi_thread", worker_threads = 4)]
+    #[cfg(any(feature = "tonic-client"))]
+    pub async fn logs_simple_tokio_multi_thread() -> Result<()> {
+        logs_simple_tokio_helper().await
+    }
+
+    #[tokio::test(flavor = "multi_thread", worker_threads = 1)]
+    #[cfg(any(feature = "tonic-client"))]
+    pub async fn logs_simple_tokio_multi_with_one_worker() -> Result<()> {
+        logs_simple_tokio_helper().await
+    }
+
+    // Ignored, to be investigated
+    #[ignore]
+    #[tokio::test(flavor = "current_thread")]
+    #[cfg(any(feature = "tonic-client"))]
+    pub async fn logs_simple_tokio_current() -> Result<()> {
+        logs_simple_tokio_helper().await
+    }
+
+    async fn logs_simple_tokio_helper() -> Result<()> {
+        use crate::{assert_logs_results, init_logs};
+        test_utils::start_collector_container().await?;
+
+        let logger_provider = init_logs(true).unwrap();
+        let layer = OpenTelemetryTracingBridge::new(&logger_provider);
+        let subscriber = tracing_subscriber::registry().with(layer);
+        info!("Tracing initialized");
+        // generate a random uuid and store it to expected guid
+        let expected_uuid = Uuid::new_v4().to_string();
+        {
+            let _guard = tracing::subscriber::set_default(subscriber);
+            info!("Tracing subscriber initialized");
+            info!(target: "my-target",  uuid = expected_uuid, "hello from {}. My price is {}.", "banana", 2.99);
+            info!("Log emitted");
+        }
+
+        let _ = logger_provider.shutdown();
+        tokio::time::sleep(Duration::from_secs(5)).await;
+        assert_logs_results(test_utils::LOGS_FILE, expected_uuid.as_str())?;
+        Ok(())
+    }
+
     #[test]
     #[cfg(any(feature = "tonic-client", feature = "reqwest-blocking-client"))]
     pub fn logs_batch_non_tokio_main() -> Result<()> {