Struct StreamEvent 

#[non_exhaustive]
pub struct StreamEvent {
    pub offset: i64,
    pub stream: String,
    pub key: Option<String>,
    pub payload: Vec<u8>,
    pub created_at: i64,
}

A stream event — honker’s shape with one rename (topic → stream, ADR-015 §3).

#[non_exhaustive] (ADR-017 §3). Offsets are positions in the stream’s log — immutable, never renumbered; order is global FIFO under publish sequence. The key is carried metadata only: not a partitioning instruction, not a dedup key, not an ordering key.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

offset: i64

Position in the stream’s log; immutable.

stream: String

The stream name.

key: Option<String>

The carried key; None unless published keyed.

payload: Vec<u8>

Payload bytes — the serde_json serialization of the trait Value at publish time (ADR-020 §4); decode with StreamEvent::payload_as.

created_at: i64

Unix seconds at publish (the engines’ single clock source).

Implementations

impl StreamEvent

pub fn payload_as<T: DeserializeOwned>(&self) -> Result<T>

Decode the stored payload bytes into a concrete target type.

The stored bytes are the serde_json serialization of the publish-time Value (ADR-020 §4); any deserialization failure is Error::Codec.

Trait Implementations

impl Clone for StreamEvent

fn clone(&self) -> Self

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 Eq for StreamEvent

impl PartialEq for StreamEvent

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StreamEvent