Skip to main content

Module export

Module export 

Source
Expand description

Event export trait for streaming HiveEvents to external observability systems.

EventExporter enables PulseHive to forward events to tools like PulseVision for real-time visualization. Implementations handle the wire protocol (WebSocket, HTTP, file, etc.); the SDK calls export() on each event emission.

§Example

use pulsehive_core::export::EventExporter;
use pulsehive_core::event::HiveEvent;

struct FileExporter { path: PathBuf }

#[async_trait]
impl EventExporter for FileExporter {
    async fn export(&self, event: &HiveEvent) {
        let json = serde_json::to_string(event).unwrap();
        tokio::fs::write(&self.path, json).await.ok();
    }
    async fn flush(&self) {}
}

Traits§

EventExporter
Trait for exporting HiveEvents to external observability systems.