Enum IndexMessage 

pub enum IndexMessage {
    Batch {
        connector_name: &'static str,
        conversations: Vec<NormalizedConversation>,
        is_discovered: bool,
        message_count: usize,
        byte_reservation: usize,
    },
    ScanError {
        connector_name: &'static str,
        error: String,
    },
    Done {
        connector_name: &'static str,
        scan_ms: u64,
        is_discovered: bool,
    },
}

Message type for streaming indexing channel.

Producers (connector scan threads) send batches of conversations through the channel. The consumer (main indexing thread) receives and ingests them.

Variants

Batch

A batch of conversations from a connector scan.

Fields

connector_name: &'static str

Connector name (e.g., “claude”, “codex”)

conversations: Vec<NormalizedConversation>

Scanned conversations

is_discovered: bool

Whether this connector was newly discovered

message_count: usize

Message count in this batch (for stats)

byte_reservation: usize

Reserved text-byte budget for this batch that must be released after ingestion.

ScanError

A scan error occurred (non-fatal, logged but continues)

Fields

connector_name: &'static str

error: String

Done

Producer has finished scanning

Fields

connector_name: &'static str

scan_ms: u64

Time spent scanning this connector (ms)

is_discovered: bool

Whether this connector was discovered even if it produced no batches