Struct OtelExporter 

pub struct OtelExporter { /* private fields */ }

OpenTelemetry audit exporter.

Exports audit events as OpenTelemetry log records to an OTLP collector using gRPC protocol.

Example

use bssh::server::audit::otel::OtelExporter;
use bssh::server::audit::exporter::AuditExporter;
use bssh::server::audit::event::{AuditEvent, EventType};

let exporter = OtelExporter::new("http://localhost:4317")?;

let event = AuditEvent::new(
    EventType::AuthSuccess,
    "alice".to_string(),
    "session-123".to_string(),
);

exporter.export(event).await?;
exporter.close().await?;

Implementations

impl OtelExporter

pub fn new(endpoint: &str) -> Result<Self>

Create a new OpenTelemetry exporter.

Arguments

• endpoint - OTLP endpoint URL (e.g., “http://localhost:4317” for local development, “https://otel-collector.example.com:4317” for production)

TLS Requirements

For production deployments, it is strongly recommended to use HTTPS endpoints to ensure audit data is transmitted securely. HTTP endpoints should only be used for local testing or when the OTLP collector is on the same trusted network.

Errors

Returns an error if:

• The endpoint URL is invalid
• The exporter cannot be initialized

Trait Implementations

impl AuditExporter for OtelExporter

fn export<'life0, 'async_trait>( &'life0 self, event: AuditEvent, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Export a single audit event.

fn export_batch<'life0, 'life1, 'async_trait>( &'life0 self, events: &'life1 [AuditEvent], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Export multiple events in a batch.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flush any buffered events.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the exporter and release resources.

impl Debug for OtelExporter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.