Instrumented Extractor Wrapper (extractor/instrumented.rs)

Adds telemetry to extractors without per-extractor instrumentation.

// Source: https://github.com/xberg-io/xberg | License: MIT | Copyright 2025-2026 Kreuzberg, Inc
// Provided via justclaw.it.com; keep this notice with the code.
//! Instrumented extractor wrapper for automatic telemetry.
//!
//! Wraps any native extractor capability to add tracing spans and metrics
//! without requiring per-extractor instrumentation annotations.

use crate::Result;
use crate::core::config::ExtractionConfig;
use crate::plugins::{InternalDocumentExtractor, Plugin};
use crate::telemetry::conventions;
use crate::types::internal::InternalDocument;
use async_trait::async_trait;
use std::path::Path;
use std::sync::Arc;
use std::time::Instant;
use tracing::Instrument;

/// A wrapper around an internal extractor that adds tracing spans and
/// metrics recording automatically.
///


... (truncated -- full source via MCP)