Struct SpectraEvent 

pub struct SpectraEvent {
    pub table: String,
    pub fields: Value,
    pub ts: Option<DateTime<Utc>>,
}

Structured event envelope for transport publish wrappers.

Consumer side: deserialize from your bus, then append via crate::EventStorageBackend or a Spectra runtime that owns events storage. Direct in-process logging usually uses a generated *Logger or try_log_event.

Examples

use serde_json::json;
use spectra_core::SpectraEvent;

let event = SpectraEvent::new(
    "request_log",
    json!({"message": "handled", "status": 200}),
);
assert_eq!(event.table, "request_log");
assert!(event.ts.is_none());

Fields

table: String

Event table name.

fields: Value

Event field payload.

ts: Option<DateTime<Utc>>

Optional explicit timestamp (defaults to sink time when absent).

Implementations

impl SpectraEvent

pub fn new(table: impl Into<String>, fields: Value) -> SpectraEvent

Creates an event without an explicit timestamp.

pub fn with_ts( table: impl Into<String>, fields: Value, ts: DateTime<Utc>, ) -> SpectraEvent

Creates an event with an explicit timestamp.

Trait Implementations

impl Clone for SpectraEvent

fn clone(&self) -> SpectraEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SpectraEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SpectraEvent

fn deserialize<__D>( __deserializer: __D, ) -> Result<SpectraEvent, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SpectraEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.