1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
// use coerce::actor::system::ActorSystem;
// use coerce::actor::{Actor, IntoActor};
// use std::error::Error;
//
// use tracing_subscriber::prelude::*;
//
// struct TracingActor;
//
// impl Actor for TracingActor {}
//
// #[tracing::instrument]
// async fn app() {
// let sys = ActorSystem::new();
//
// for i in 0..10 {
// let actor_id = format!("actor-id-{}", i);
// tracing::info!(actor_id = actor_id.as_str(), message = "starting actor",);
//
// TracingActor
// .into_actor(Some(format!("actor-id-{}", i)), &sys)
// .await;
// }
// }
//
// #[tokio::test]
// pub async fn test_tracing() -> Result<(), Box<dyn Error + Send + Sync + 'static>> {
// // tracing_subscriber::fmt()
// // .with_max_level(tracing::Level::TRACE)
// // // .with_span_events(FmtSpan::FULL)
// // .try_init()?;
//
// let tracer = opentelemetry_jaeger::new_pipeline()
// .with_service_name("coerce")
// .install_simple()?;
//
// let opentelemetry = tracing_opentelemetry::layer().with_tracer(tracer);
// tracing_subscriber::registry()
// .with(opentelemetry)
// .try_init()?;
//
// app().await;
//
// Ok(())
// }