Enum EventPayload 

#[non_exhaustive]
pub enum EventPayload {
    ProfilingStarted {
        source: String,
    },
    ProfilingCompleted {
        source: String,
        fields: usize,
        rows: usize,
        duration_ms: u64,
    },
    MaterializationStarted {
        entity: String,
        platform: String,
    },
    MaterializationCompleted {
        entity: String,
        platform: String,
        artifacts: usize,
        duration_ms: u64,
    },
    MaterializationFailed {
        design: String,
        platform: String,
        message: String,
    },
    DesignValidated {
        design: String,
        errors: usize,
        warnings: usize,
    },
    DesignLoaded {
        path: String,
        entities: usize,
    },
    PluginLoaded {
        name: String,
        plugin_type: String,
        source: String,
    },
    StorageOperationCompleted {
        operation: String,
        path: String,
        bytes: u64,
        duration_ms: u64,
    },
    StorageWarning {
        entity: String,
        feature: String,
        platform: String,
        recommendation: String,
    },
    LlmRequestCompleted {
        provider: String,
        model: String,
        tokens: u64,
        duration_ms: u64,
    },
    FileRouted {
        path: String,
        destination: String,
        rule: String,
        bytes: u64,
    },
    FileSetAside {
        path: String,
        destination: String,
        reason: String,
    },
    FileNotMoved {
        path: String,
        reason: String,
    },
    ScanCompleted {
        location: String,
        files: usize,
        routed: usize,
        set_aside: usize,
        not_moved: usize,
        duration_ms: u64,
    },
}

Structured payload variants carried by the event envelope.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

ProfilingStarted

Data profiling started on a source.

Fields

source: String

Name of the data source being profiled.

ProfilingCompleted

Data profiling completed.

Fields

source: String

Name of the data source that was profiled.

fields: usize

Number of fields discovered.

rows: usize

Number of rows sampled.

duration_ms: u64

Duration of the profiling run in milliseconds.

MaterializationStarted

SQL materialization started for an entity.

Fields

entity: String

Name of the entity being materialized.

platform: String

Target SQL platform name.

MaterializationCompleted

SQL materialization completed.

Fields

entity: String

Name of the entity that was materialized.

platform: String

Target SQL platform name.

artifacts: usize

Number of SQL artifacts produced.

duration_ms: u64

Duration of the materialization run in milliseconds.

MaterializationFailed

SQL materialization failed.

Fields

design: String

Name of the design that failed.

platform: String

Target SQL platform name.

message: String

Human-readable failure description.

DesignValidated

Design validated with warning and error counts.

Fields

design: String

Name of the validated design.

errors: usize

Number of validation errors.

warnings: usize

Number of validation warnings.

DesignLoaded

Design document loaded.

Fields

path: String

File path or URI from which the design was loaded.

entities: usize

Number of entities in the design.

PluginLoaded

A plugin was loaded.

Fields

name: String

Plugin name.

plugin_type: String

Plugin extension point type (e.g. "dialect").

source: String

Source description (e.g. "static" or a library path).

StorageOperationCompleted

Storage I/O operation completed.

Fields

operation: String

Operation name (e.g. "put", "get", "delete").

path: String

Storage path of the object.

bytes: u64

Number of bytes transferred.

duration_ms: u64

Duration of the operation in milliseconds.

StorageWarning

Materializer detected a storage feature that the target platform cannot honor. Emitted instead of panicking (TP-010).

Fields

entity: String

Name of the entity that triggered the warning.

feature: String

Storage feature that is unsupported.

platform: String

Target SQL platform name.

recommendation: String

Suggested alternative or workaround.

LlmRequestCompleted

LLM request completed.

Fields

provider: String

LLM provider name.

model: String

Model identifier used for the request.

tokens: u64

Total tokens consumed.

duration_ms: u64

Duration of the request in milliseconds.

FileRouted

A file the agent found was moved to where a routing rule sends it.

Fields

path: String

Where the file was found.

destination: String

Where it was moved to.

rule: String

The routing rule that sent it there.

bytes: u64

Its size in bytes.

FileSetAside

A file the agent found was set aside: no rule routes it, or it failed a check. A warning, so a person looks at it.

Fields

path: String

Where the file was found.

destination: String

Where it was set aside.

reason: String

Why, in a reader’s words.

FileNotMoved

A file the agent found could not be moved at all, and stays where it was. An error.

Fields

path: String

Where the file is.

reason: String

What stopped the move, in a reader’s words.

ScanCompleted

The agent finished one pass over a landing location.

Fields

location: String

The location scanned.

files: usize

Files found.

routed: usize

Of those, routed.

set_aside: usize

Of those, set aside.

not_moved: usize

Of those, not moved.

duration_ms: u64

How long the pass took, in milliseconds.

Implementations

impl EventPayload

pub fn category(&self) -> EventCategory

Category derived from the payload variant.

pub fn severity(&self) -> EventSeverity

Severity derived from the payload variant.

pub fn requires_workflow_context(&self) -> bool

Whether this payload must be correlated to a workflow.

Trait Implementations

impl Clone for EventPayload

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventPayload

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventPayload

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for EventPayload

impl PartialEq for EventPayload

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for EventPayload

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for EventPayload