Struct InternalEvent 

pub struct InternalEvent {
    pub raw: Bytes,
    pub insertion_ts: u64,
    pub shard_id: u16,
}

Internal event representation with metadata assigned at ingestion.

This is the canonical form of an event within the event bus. The insertion_ts provides deterministic ordering within a shard.

Uses Bytes for zero-copy, reference-counted storage.

Fields

raw: Bytes

Pre-serialized JSON payload (reference-counted, zero-copy clone).

insertion_ts: u64

Monotonically increasing insertion timestamp (nanoseconds). Strictly ordered within a shard, not globally.

shard_id: u16

Shard this event was assigned to.

Implementations

impl InternalEvent

pub fn new(raw: Bytes, insertion_ts: u64, shard_id: u16) -> Self

Create a new internal event from raw bytes.

pub fn from_value(value: JsonValue, insertion_ts: u64, shard_id: u16) -> Self

Create from a JSON value (serializes once).

See RawEvent::from_value for the rationale on unwrap_or_default() instead of expect().

pub fn parse(&self) -> Result<JsonValue, Error>

Parse the raw bytes into a JSON value.

pub fn as_bytes(&self) -> &[u8]

Get the raw bytes as a slice.

Trait Implementations

impl Clone for InternalEvent

fn clone(&self) -> InternalEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InternalEvent

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

Formats the value using the given formatter.