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§
- Event
Exporter - Trait for exporting HiveEvents to external observability systems.