Struct Event 

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

A single conversation event: a kind tag, a TrustTag provenance capability, 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. trust is the CaMeL-style trust tag assigned at ingress (see TrustTag); it travels with the event through the durable log so a data-flow policy can reason over provenance without re-decoding payloads.

The position (turn/seq ordering) is not carried in the event itself: the journal assigns each appended event a monotonically increasing position, and the physical journal adapter yields events in that append order. See the adapter’s documentation for the ordering contract.

Fields

kind: String

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

trust: TrustTag

Provenance/trust capability assigned at ingress.

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 unclassified (TrustTag::Unspecified) event from a kind and an owned payload — for control/marker events that carry no external content provenance.

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

Construct a TrustTag::TrustedUser event — an authenticated principal’s own message.

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

Construct a TrustTag::QuarantinedContent event — tool output, fetched content, or otherwise untrusted inbound content.

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

Construct an event with an explicit TrustTag.

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

Equality operator ==.

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

Inequality operator !=.

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.