Struct Event 

pub struct Event {
    pub event_type: EventType,
    pub version: u16,
    pub timestamp_ms: u64,
    pub correlation_id: String,
    pub source: String,
    pub data: HashMap<String, String>,
    pub severity: EventSeverity,
    pub event_id: String,
}

Versioned event data used by the opt-in historical scanner event bus.

Examples

use termivar_core::{Event, EventSeverity, EventType};

let event = Event::builder(EventType::PhaseStarted, "scanner")
    .correlation_id("scan-42")
    .severity(EventSeverity::Info)
    .data("phase", "recon")
    .build();

assert_eq!(event.event_type, EventType::PhaseStarted);
assert_eq!(event.correlation_id, "scan-42");

Fields

event_type: EventType

version: u16

timestamp_ms: u64

correlation_id: String

source: String

data: HashMap<String, String>

severity: EventSeverity

event_id: String

Implementations

impl Event

pub fn new(event_type: EventType, source: impl Into<String>) -> Self

Creates an event with a generated timestamp, correlation ID, and event ID.

pub fn builder(event_type: EventType, source: impl Into<String>) -> EventBuilder

Creates a fluent event builder.

pub fn with_correlation_id(self, scan_id: impl Into<String>) -> Self

Replaces the correlation ID.

pub fn with_data(self, key: impl Into<String>, value: impl Into<String>) -> Self

Adds a custom data field.

pub fn with_severity(self, severity: EventSeverity) -> Self

Replaces the event severity.

pub fn with_version(self, version: u16) -> Self

Replaces the event schema version.

pub fn timestamp_str(&self) -> String

Returns the timestamp in seconds.milliseconds form.

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Event

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Event

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Event

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

where __S: Serializer,

Serialize this value into the given Serde serializer.