Struct StoredEvent 

pub struct StoredEvent {
    pub id: String,
    pub raw: Bytes,
    pub insertion_ts: u64,
    pub shard_id: u16,
    pub dedup_id: Option<String>,
}

An event retrieved from storage with its backend-specific ID.

Fields

id: String

Backend-specific identifier.

raw: Bytes

Raw JSON payload bytes (deferred parsing for performance).

insertion_ts: u64

Insertion timestamp from ingestion.

shard_id: u16

Shard this event belongs to.

dedup_id: Option<String>

Application-level idempotency key as written by the producer. Adapters carry an opaque dedup token on the wire (Redis Streams uses a dedup_id field; JetStream uses Nats-Msg-Id). The trait-level consumer (crate::adapter::Adapter::poll_shard) surfaces it here so callers can drive their own dedup table without re-reading the raw broker payload. None when the adapter or the wire entry doesn’t carry one.

Implementations

impl StoredEvent

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

Create a new stored event from raw bytes.

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

Create a new stored event from a JSON value (serializes once).

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

pub fn with_dedup_id(self, dedup_id: Option<String>) -> Self

Attach an application-level dedup identifier (the producer’s dedup_id / Nats-Msg-Id). Returns self for chaining.

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

Parse the raw bytes into a JSON value on demand.

pub fn raw_str(&self) -> Result<&str, Utf8Error>

Get the raw bytes as a string slice (for serialization).

Returns Err if the raw bytes are not valid UTF-8, rather than silently substituting data.

Trait Implementations

impl Clone for StoredEvent

fn clone(&self) -> StoredEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StoredEvent

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

Formats the value using the given formatter.

impl Serialize for StoredEvent

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.