Enum StreamEvent 

pub enum StreamEvent {
    TripleAdded {
        subject: String,
        predicate: String,
        object: String,
        graph: Option<String>,
        metadata: EventMetadata,
    },
    TripleRemoved {
        subject: String,
        predicate: String,
        object: String,
        graph: Option<String>,
        metadata: EventMetadata,
    },
    QuadAdded {
        subject: String,
        predicate: String,
        object: String,
        graph: String,
        metadata: EventMetadata,
    },
    QuadRemoved {
        subject: String,
        predicate: String,
        object: String,
        graph: String,
        metadata: EventMetadata,
    },
    GraphCreated {
        graph: String,
        metadata: EventMetadata,
    },
    GraphCleared {
        graph: Option<String>,
        metadata: EventMetadata,
    },
    GraphDeleted {
        graph: String,
        metadata: EventMetadata,
    },
    SparqlUpdate {
        query: String,
        operation_type: SparqlOperationType,
        metadata: EventMetadata,
    },
    TransactionBegin {
        transaction_id: String,
        isolation_level: Option<IsolationLevel>,
        metadata: EventMetadata,
    },
    TransactionCommit {
        transaction_id: String,
        metadata: EventMetadata,
    },
    TransactionAbort {
        transaction_id: String,
        metadata: EventMetadata,
    },
    SchemaChanged {
        schema_type: SchemaType,
        change_type: SchemaChangeType,
        details: String,
        metadata: EventMetadata,
    },
    Heartbeat {
        timestamp: DateTime<Utc>,
        source: String,
        metadata: EventMetadata,
    },
    QueryResultAdded {
        query_id: String,
        result: QueryResult,
        metadata: EventMetadata,
    },
    QueryResultRemoved {
        query_id: String,
        result: QueryResult,
        metadata: EventMetadata,
    },
    QueryCompleted {
        query_id: String,
        execution_time: Duration,
        metadata: EventMetadata,
    },
    GraphMetadataUpdated {
        graph: String,
        metadata_type: String,
        old_value: Option<String>,
        new_value: String,
        metadata: EventMetadata,
    },
    GraphPermissionsChanged {
        graph: String,
        permission_type: String,
        principal: String,
        granted: bool,
        metadata: EventMetadata,
    },
    GraphStatisticsUpdated {
        graph: String,
        triple_count: u64,
        size_bytes: u64,
        last_modified: u64,
        metadata: EventMetadata,
    },
    GraphRenamed {
        old_name: String,
        new_name: String,
        metadata: EventMetadata,
    },
    GraphMerged {
        source_graphs: Vec<String>,
        target_graph: String,
        metadata: EventMetadata,
    },
    GraphSplit {
        source_graph: String,
        target_graphs: Vec<String>,
        split_criteria: String,
        metadata: EventMetadata,
    },
    SchemaDefinitionAdded {
        schema_type: String,
        schema_uri: String,
        definition: String,
        metadata: EventMetadata,
    },
    SchemaDefinitionRemoved {
        schema_type: String,
        schema_uri: String,
        metadata: EventMetadata,
    },
    SchemaDefinitionModified {
        schema_type: String,
        schema_uri: String,
        old_definition: String,
        new_definition: String,
        metadata: EventMetadata,
    },
    OntologyImported {
        ontology_uri: String,
        version: Option<String>,
        import_method: String,
        metadata: EventMetadata,
    },
    OntologyRemoved {
        ontology_uri: String,
        version: Option<String>,
        metadata: EventMetadata,
    },
    ConstraintAdded {
        constraint_type: String,
        target: String,
        constraint_definition: String,
        metadata: EventMetadata,
    },
    ConstraintRemoved {
        constraint_type: String,
        target: String,
        constraint_definition: String,
        metadata: EventMetadata,
    },
    ConstraintViolated {
        constraint_type: String,
        target: String,
        violating_data: String,
        severity: String,
        metadata: EventMetadata,
    },
    IndexCreated {
        index_name: String,
        index_type: String,
        target_properties: Vec<String>,
        graph: Option<String>,
        metadata: EventMetadata,
    },
    IndexDropped {
        index_name: String,
        index_type: String,
        metadata: EventMetadata,
    },
    IndexRebuilt {
        index_name: String,
        reason: String,
        duration_ms: u64,
        metadata: EventMetadata,
    },
    SchemaUpdated {
        schema_uri: String,
        update_type: String,
        old_definition: Option<String>,
        new_definition: String,
        metadata: EventMetadata,
    },
    ShapeAdded {
        shape_uri: String,
        shape_definition: String,
        target_class: Option<String>,
        metadata: EventMetadata,
    },
    ShapeUpdated {
        shape_uri: String,
        old_definition: String,
        new_definition: String,
        target_class: Option<String>,
        metadata: EventMetadata,
    },
    ShapeRemoved {
        shape_uri: String,
        metadata: EventMetadata,
    },
    ShapeModified {
        shape_uri: String,
        old_definition: String,
        new_definition: String,
        metadata: EventMetadata,
    },
    ShapeValidationStarted {
        shape_uri: String,
        target_graph: Option<String>,
        validation_id: String,
        metadata: EventMetadata,
    },
    ShapeValidationCompleted {
        shape_uri: String,
        validation_id: String,
        success: bool,
        violation_count: u32,
        duration_ms: u64,
        metadata: EventMetadata,
    },
    ShapeViolationDetected {
        shape_uri: String,
        violation_path: String,
        violating_node: String,
        severity: String,
        message: String,
        metadata: EventMetadata,
    },
    ErrorOccurred {
        error_type: String,
        error_message: String,
        error_context: Option<String>,
        metadata: EventMetadata,
    },
}

Enhanced RDF streaming events with metadata and provenance

Variants

TripleAdded

Fields

subject: String

predicate: String

object: String

graph: Option<String>

metadata: EventMetadata

TripleRemoved

Fields

subject: String

predicate: String

object: String

graph: Option<String>

metadata: EventMetadata

QuadAdded

Fields

subject: String

predicate: String

object: String

graph: String

metadata: EventMetadata

QuadRemoved

Fields

subject: String

predicate: String

object: String

graph: String

metadata: EventMetadata

GraphCreated

Fields

graph: String

metadata: EventMetadata

GraphCleared

Fields

graph: Option<String>

metadata: EventMetadata

GraphDeleted

Fields

graph: String

metadata: EventMetadata

SparqlUpdate

Fields

query: String

operation_type: SparqlOperationType

metadata: EventMetadata

TransactionBegin

Fields

transaction_id: String

isolation_level: Option<IsolationLevel>

metadata: EventMetadata

TransactionCommit

Fields

transaction_id: String

metadata: EventMetadata

TransactionAbort

Fields

transaction_id: String

metadata: EventMetadata

SchemaChanged

Fields

schema_type: SchemaType

change_type: SchemaChangeType

details: String

metadata: EventMetadata

Heartbeat

Fields

timestamp: DateTime<Utc>

source: String

metadata: EventMetadata

QueryResultAdded

Fields

query_id: String

result: QueryResult

metadata: EventMetadata

QueryResultRemoved

Fields

query_id: String

result: QueryResult

metadata: EventMetadata

QueryCompleted

Fields

query_id: String

execution_time: Duration

metadata: EventMetadata

GraphMetadataUpdated

Fields

graph: String

metadata_type: String

old_value: Option<String>

new_value: String

metadata: EventMetadata

GraphPermissionsChanged

Fields

graph: String

permission_type: String

principal: String

granted: bool

metadata: EventMetadata

GraphStatisticsUpdated

Fields

graph: String

triple_count: u64

size_bytes: u64

last_modified: u64

metadata: EventMetadata

GraphRenamed

Fields

old_name: String

new_name: String

metadata: EventMetadata

GraphMerged

Fields

source_graphs: Vec<String>

target_graph: String

metadata: EventMetadata

GraphSplit

Fields

source_graph: String

target_graphs: Vec<String>

split_criteria: String

metadata: EventMetadata

SchemaDefinitionAdded

Fields

schema_type: String

schema_uri: String

definition: String

metadata: EventMetadata

SchemaDefinitionRemoved

Fields

schema_type: String

schema_uri: String

metadata: EventMetadata

SchemaDefinitionModified

Fields

schema_type: String

schema_uri: String

old_definition: String

new_definition: String

metadata: EventMetadata

OntologyImported

Fields

ontology_uri: String

version: Option<String>

import_method: String

metadata: EventMetadata

OntologyRemoved

Fields

ontology_uri: String

version: Option<String>

metadata: EventMetadata

ConstraintAdded

Fields

constraint_type: String

target: String

constraint_definition: String

metadata: EventMetadata

ConstraintRemoved

Fields

constraint_type: String

target: String

constraint_definition: String

metadata: EventMetadata

ConstraintViolated

Fields

constraint_type: String

target: String

violating_data: String

severity: String

metadata: EventMetadata

IndexCreated

Fields

index_name: String

index_type: String

target_properties: Vec<String>

graph: Option<String>

metadata: EventMetadata

IndexDropped

Fields

index_name: String

index_type: String

metadata: EventMetadata

IndexRebuilt

Fields

index_name: String

reason: String

duration_ms: u64

metadata: EventMetadata

SchemaUpdated

Fields

schema_uri: String

update_type: String

old_definition: Option<String>

new_definition: String

metadata: EventMetadata

ShapeAdded

Fields

shape_uri: String

shape_definition: String

target_class: Option<String>

metadata: EventMetadata

ShapeUpdated

Fields

shape_uri: String

old_definition: String

new_definition: String

target_class: Option<String>

metadata: EventMetadata

ShapeRemoved

Fields

shape_uri: String

metadata: EventMetadata

ShapeModified

Fields

shape_uri: String

old_definition: String

new_definition: String

metadata: EventMetadata

ShapeValidationStarted

Fields

shape_uri: String

target_graph: Option<String>

validation_id: String

metadata: EventMetadata

ShapeValidationCompleted

Fields

shape_uri: String

validation_id: String

success: bool

violation_count: u32

duration_ms: u64

metadata: EventMetadata

ShapeViolationDetected

Fields

shape_uri: String

violation_path: String

violating_node: String

severity: String

message: String

metadata: EventMetadata

ErrorOccurred

Fields

error_type: String

error_message: String

error_context: Option<String>

metadata: EventMetadata

Implementations

impl StreamEvent

pub fn timestamp(&self) -> DateTime<Utc>

Extract timestamp from any StreamEvent variant

pub fn event_id(&self) -> &str

Extract event ID from any StreamEvent variant

impl StreamEvent

pub fn metadata(&self) -> &EventMetadata

Get the metadata for this event

pub fn graph_metadata_updated( graph: String, metadata_type: String, old_value: Option<String>, new_value: String, ) -> Self

Create a named graph metadata update event

pub fn graph_permissions_changed( graph: String, permission_type: String, principal: String, granted: bool, ) -> Self

Create a graph permissions change event

pub fn graph_statistics_updated( graph: String, triple_count: u64, size_bytes: u64, ) -> Self

Create a graph statistics update event

pub fn schema_definition_added( schema_type: String, schema_uri: String, definition: String, ) -> Self

Create a schema definition added event

pub fn schema_definition_modified( schema_type: String, schema_uri: String, old_definition: String, new_definition: String, ) -> Self

Create a schema definition modified event

pub fn ontology_imported( ontology_uri: String, version: Option<String>, import_method: String, ) -> Self

Create an ontology import event

pub fn constraint_violated( constraint_type: String, target: String, violating_data: String, severity: String, ) -> Self

Create a constraint violation event

pub fn index_created( index_name: String, index_type: String, target_properties: Vec<String>, graph: Option<String>, ) -> Self

Create an index creation event

pub fn shape_added( shape_uri: String, shape_definition: String, target_class: Option<String>, ) -> Self

Create a SHACL shape added event

pub fn shape_validation_completed( shape_uri: String, validation_id: String, success: bool, violation_count: u32, duration_ms: u64, ) -> Self

Create a SHACL shape validation completed event

pub fn shape_violation_detected( shape_uri: String, violation_path: String, violating_node: String, severity: String, message: String, ) -> Self

Create a SHACL shape violation detected event

pub fn category(&self) -> EventCategory

Get the event category for classification

pub fn event_type(&self) -> StreamEventType

Get the specific event type for filtering and classification

pub fn affects_graph(&self, target_graph: &str) -> bool

Check if this event affects a specific graph

pub fn priority(&self) -> EventPriority

Get the priority level of this event

Trait Implementations

impl Clone for StreamEvent

fn clone(&self) -> StreamEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl EventMetadataAccessor for StreamEvent

fn metadata(&self) -> &EventMetadata

impl Serialize for StreamEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.