ank/avarus
1
Fork 0
Code Issues Activity

more vaccilation

Browse source
This commit is contained in:
Andy Killorin 2023-12-25 00:39:18 -06:00
parent 17422f4cdd
commit b2c41261de
Signed by: ank
GPG key ID: B6241CA3B552BCA4
2 changed files with 14 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
server/Cargo.toml
View file

@ -20,6 +20,10 @@ hyper-util = "0.1.1"
indoc = "2.0.4" indoc = "2.0.4"
nalgebra = { version = "0.32.3", features = ["serde-serialize"] } nalgebra = { version = "0.32.3", features = ["serde-serialize"] }
opentelemetry = "0.21.0" opentelemetry = "0.21.0"
opentelemetry-appender-tracing = "0.2.0"
opentelemetry-jaeger = "0.20.0"
opentelemetry-otlp = { version = "0.14.0", features = ["logs", "http-proto", "reqwest-client"] }
opentelemetry-semantic-conventions = "0.13.0"
opentelemetry-stdout = { version = "0.2.0", features = ["trace"] } opentelemetry-stdout = { version = "0.2.0", features = ["trace"] }
opentelemetry_sdk = { version = "0.21.1", features = ["logs", "rt-tokio"] } opentelemetry_sdk = { version = "0.21.1", features = ["logs", "rt-tokio"] }
parking_lot = { version = "0.11", features = ["serde"] } parking_lot = { version = "0.11", features = ["serde"] }

19
server/src/main.rs
View file

@ -24,6 +24,7 @@ use indoc::formatdoc;
use opentelemetry::trace::TracerProvider as _; use opentelemetry::trace::TracerProvider as _;
use opentelemetry_sdk::{trace::TracerProvider, runtime::Tokio}; use opentelemetry_sdk::{trace::TracerProvider, runtime::Tokio};
use opentelemetry_stdout as stdout; use opentelemetry_stdout as stdout;
use tracing_subscriber::prelude::*;
use tracing_subscriber::layer::SubscriberExt; use tracing_subscriber::layer::SubscriberExt;
use tracing_subscriber::Registry; use tracing_subscriber::Registry;
@ -57,16 +58,16 @@ async fn main() -> Result<(), Error> {
None => "save".into(), None => "save".into(),
})?; })?;
let provider = TracerProvider::builder() let tracer = opentelemetry_jaeger::new_agent_pipeline()
.with_batch_exporter(opentelemetry_stdout::SpanExporter::default(),Tokio) .with_service_name("avarus")
.build(); .install_simple()?;
let opentelemetry = tracing_opentelemetry::layer().with_tracer(tracer);
tracing_subscriber::registry()
.with(opentelemetry)
.try_init()?;
let tracer = provider.tracer("avarus"); let root = span!(tracing::Level::INFO, "starting");
let enter = root.enter();
let telemetry = tracing_opentelemetry::layer().with_tracer(tracer);
let subscriber = Registry::default().with(telemetry);
tracing::subscriber::set_global_default(subscriber)?;
info!("started"); info!("started");