Method build

libs/@local/telemetry/src/lib.rs:119–188

(self)

    }

    fn build(self) -> Result<(impl Into<Dispatch>, impl Drop), Report<InitTracingError>> {
        let error_layer = self.error_layer.then(ErrorLayer::default);
        let console_layer = self
            .console_logging
            .as_ref()
            .map(self::logging::console_layer);

        let (file_layer, file_guard) = self.file_logging.map(self::logging::file_layer).unzip();

        let sentry_layer = self.sentry.as_ref().map(self::traces::sentry::layer);

        let (otlp_logs_layer, otlp_logs_provider) = self
            .otlp
            .as_ref()
            .map(|(otlp, service_name)| {
                self::logging::otlp::provider(otlp, service_name)
                    .change_context(InitTracingError)
                    .map(|provider| (self::logging::otlp::layer(&provider), provider))
            })
            .transpose()?
            .unzip();

        let (otlp_traces_layer, otlp_traces_provider) = self
            .otlp
            .as_ref()
            .map(|(otlp, service_name)| {
                self::traces::otlp::provider(otlp, service_name)
                    .change_context(InitTracingError)
                    .map(|provider| (self::traces::otlp::layer(&provider), provider))
            })
            .transpose()?
            .unzip();

        let otlp_metrics_provider = self
            .otlp
            .as_ref()
            .map(|(otlp, service_name)| {
                self::metrics::otlp::provider(otlp, service_name).change_context(InitTracingError)
            })
            .transpose()?;

        let (flame_layer, flamegraph_guard) = self
            .flamegraph_path
            .map(|path| {
                fs::create_dir_all(&path).change_context(InitTracingError)?;
                FlameLayer::with_file(path.join("tracing.folded")).change_context(InitTracingError)
            })
            .transpose()?
            .unzip();

        let guard = TelemetryGuard {
            otlp_traces_provider,
            otlp_logs_provider,
            otlp_metrics_provider,
            _file_guard: file_guard,
            _flamegraph: flamegraph_guard,
        };