Struct Event 

pub struct Event {
    pub kind: String,
    pub payload: Vec<u8>,
}

A single conversation event: a kind tag and an opaque encoded payload.

kind is a short string discriminator (e.g. "user_msg", "planner_decision", "tool_call"). payload is opaque to this crate — it is the buffa-encoded body of whichever events.proto message the kind names, stored and replayed byte-for-byte.

The position (turn/seq ordering) is not carried in the event itself: the journal assigns each appended event a monotonically increasing position, and crate::EventLog::replay yields events in that append order. See the crate docs for the ordering contract.

Fields

kind: String

Discriminator naming the payload’s schema (e.g. "tool_call").

payload: Vec<u8>

Opaque, buffa-encoded payload bytes. Round-tripped verbatim.

Implementations

impl Event

pub fn new(kind: impl Into<String>, payload: Vec<u8>) -> Self

Construct an Event from a kind and an owned payload byte vector.

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 EncodeSize for Event

fn encode_size(&self) -> usize

Returns the encoded size of this value (in bytes).

fn encode_inline_size(&self) -> usize

Returns the encoded size excluding bytes passed to BufsMut::push during Write::write_bufs. Used to size the working buffer for inline writes. Override alongside Write::write_bufs for types where large Bytes fields go via push; failing to do so will over-allocate.

impl Eq for Event

impl PartialEq for Event

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Read for Event

type Cfg = EventCfg

The Cfg type parameter allows passing configuration during the read process. This is crucial for safely decoding untrusted data, for example, by providing size limits for collections or strings.

fn read_cfg(buf: &mut impl Buf, cfg: &EventCfg) -> Result<Self, CodecError>

Reads a value from the buffer using the provided configuration cfg.

impl StructuralPartialEq for Event

impl Write for Event

fn write(&self, buf: &mut impl BufMut)

Writes the binary representation of self to the provided buffer buf.

fn write_bufs(&self, buf: &mut impl BufsMut)

Writes to a BufsMut, allowing existing Bytes chunks to be appended via BufsMut::push instead of written inline. Must encode to the same format as Write::write. Defaults to Write::write.