Skip to main content

Module stream_client

Module stream_client 

Source
Expand description

Streaming HTTP client for pushing unified JSONL to a RustGraph ingest endpoint.

Implements std::io::Write so it can be passed directly to RustGraphUnifiedExporter::export_to_writer. Buffers JSONL lines in memory and auto-flushes when batch size is reached.

Structsยง

StreamClient
HTTP streaming client that implements Write for JSONL output.
StreamConfig
Configuration for the streaming client.