mirror of
https://github.com/kjuulh/dagger-rs.git
synced 2025-08-04 14:53:25 +02:00
feat: with opentelemetry
This commit is contained in:
@@ -7,13 +7,28 @@ use dagger_core::engine::Engine as DaggerEngine;
|
||||
|
||||
use crate::errors::ConnectError;
|
||||
use crate::gen::Query;
|
||||
use crate::logging::StdLogger;
|
||||
use crate::logging::{StdLogger, TracingLogger};
|
||||
use crate::querybuilder::query;
|
||||
|
||||
pub type DaggerConn = Arc<Query>;
|
||||
|
||||
pub async fn connect() -> Result<DaggerConn, ConnectError> {
|
||||
let cfg = Config::new(None, None, None, None, Some(Arc::new(StdLogger::default())));
|
||||
let cfg = if cfg!(feature = "otel") {
|
||||
let cfg = Config::new(
|
||||
None,
|
||||
None,
|
||||
None,
|
||||
None,
|
||||
Some(Arc::new(TracingLogger::default())),
|
||||
);
|
||||
|
||||
#[cfg(feature = "otel")]
|
||||
crate::logging::otel_logging().map_err(ConnectError::FailedToInstallOtelTracer)?;
|
||||
|
||||
cfg
|
||||
} else {
|
||||
Config::new(None, None, None, None, Some(Arc::new(StdLogger::default())))
|
||||
};
|
||||
|
||||
connect_opts(cfg).await
|
||||
}
|
||||
|
Reference in New Issue
Block a user