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,
    },
}

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.

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