Enum CortexEvent 

pub enum CortexEvent {
    MapStarted {
        domain: String,
        timestamp: String,
    },
    SitemapDiscovered {
        domain: String,
        url_count: usize,
        elapsed_ms: u64,
    },
    HeadScanProgress {
        domain: String,
        scanned: usize,
        total: usize,
        live: usize,
        dead: usize,
    },
    StructuredDataExtracted {
        domain: String,
        pages_fetched: usize,
        jsonld_found: usize,
        opengraph_found: usize,
        patterns_used: usize,
        elapsed_ms: u64,
    },
    LayerComplete {
        domain: String,
        layer: u8,
        layer_name: String,
        nodes_added: usize,
        features_filled: usize,
        elapsed_ms: u64,
    },
    MapComplete {
        domain: String,
        node_count: usize,
        edge_count: usize,
        page_types: usize,
        total_ms: u64,
        browser_contexts_used: usize,
        jsonld_coverage: f32,
    },
    MapFailed {
        domain: String,
        error: String,
        elapsed_ms: u64,
    },
    ActionStarted {
        domain: String,
        node: usize,
        action_type: String,
        execution_path: String,
    },
    ActionComplete {
        domain: String,
        node: usize,
        action_type: String,
        success: bool,
        execution_path: String,
        elapsed_ms: u64,
    },
    AuthStarted {
        domain: String,
        method: String,
    },
    AuthComplete {
        domain: String,
        method: String,
        success: bool,
    },
    AuthConsentRequired {
        domain: String,
        provider: String,
        scopes: Vec<String>,
    },
    QueryExecuted {
        domain: String,
        query_type: String,
        results_count: usize,
        elapsed_us: u64,
    },
    RuntimeStarted {
        version: String,
        http_port: Option<u16>,
        socket_path: String,
    },
    AgentConnected {
        agent_type: String,
        agent_name: Option<String>,
    },
    AgentDisconnected {
        agent_type: String,
    },
    CacheStatus {
        maps_cached: usize,
        total_nodes: usize,
        memory_mb: f32,
    },
}

Every event Cortex emits. Serialized to JSON for SSE, MCP, and socket streaming.

Variants

MapStarted

A new mapping operation has started.

Fields

domain: String

timestamp: String

SitemapDiscovered

Sitemap/robots.txt discovery found URLs.

Fields

domain: String

url_count: usize

elapsed_ms: u64

HeadScanProgress

HEAD scan progress (emitted every ~500 URLs for large scans).

Fields

domain: String

scanned: usize

total: usize

live: usize

dead: usize

StructuredDataExtracted

Structured data extraction complete for a batch of pages.

Fields

domain: String

pages_fetched: usize

jsonld_found: usize

opengraph_found: usize

patterns_used: usize

elapsed_ms: u64

LayerComplete

A mapping layer finished processing.

Fields

domain: String

layer: u8

layer_name: String

nodes_added: usize

features_filled: usize

elapsed_ms: u64

MapComplete

Mapping completed successfully.

Fields

domain: String

node_count: usize

edge_count: usize

page_types: usize

total_ms: u64

browser_contexts_used: usize

jsonld_coverage: f32

MapFailed

Mapping failed with an error.

Fields

domain: String

error: String

elapsed_ms: u64

ActionStarted

An action (add to cart, submit form, etc.) has started.

Fields

domain: String

node: usize

action_type: String

execution_path: String

ActionComplete

An action completed.

Fields

domain: String

node: usize

action_type: String

success: bool

execution_path: String

elapsed_ms: u64

AuthStarted

Authentication flow started.

Fields

domain: String

method: String

AuthComplete

Authentication flow completed.

Fields

domain: String

method: String

success: bool

AuthConsentRequired

User consent is required for OAuth/SSO.

Fields

domain: String

provider: String

scopes: Vec<String>

QueryExecuted

A query/pathfind operation was executed.

Fields

domain: String

query_type: String

results_count: usize

elapsed_us: u64

RuntimeStarted

Cortex runtime started.

Fields

version: String

http_port: Option<u16>

socket_path: String

AgentConnected

An agent client connected.

Fields

agent_type: String

agent_name: Option<String>

AgentDisconnected

An agent client disconnected.

Fields

agent_type: String

CacheStatus

Periodic cache status update.

Fields

maps_cached: usize

total_nodes: usize

memory_mb: f32

Trait Implementations

impl Clone for CortexEvent

fn clone(&self) -> CortexEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CortexEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CortexEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CortexEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.