Struct EAppend 

pub struct EAppend {
    pub stream_id: StreamId,
    pub event_name: String,
    pub event_id: Option<Uuid>,
    pub partition_key: Option<Uuid>,
    pub expected_version: ExpectedVersion,
    pub timestamp: Option<u64>,
    pub payload: Vec<u8>,
    pub metadata: Vec<u8>,
}

Append an event to a stream.

Syntax

EAPPEND <stream_id> <event_name> [EVENT_ID <event_id>] [PARTITION_KEY <partition_key>] [EXPECTED_VERSION <version>] [TIMESTAMP <timestamp>] [PAYLOAD <payload>] [METADATA <metadata>]

Parameters

• stream_id: Stream identifier to append the event to
• event_name: Name/type of the event
• event_id (optional): UUID for the event (auto-generated if not provided)
• partition_key (optional): UUID to determine event partitioning
• expected_version (optional): Expected stream version (number, “any”, “exists”, “empty”)
• payload (optional): Event payload data
• metadata (optional): Event metadata

Example

EAPPEND my-stream UserCreated PAYLOAD '{"name":"john"}' METADATA '{"source":"api"}'

Fields

stream_id: StreamId

event_name: String

event_id: Option<Uuid>

partition_key: Option<Uuid>

expected_version: ExpectedVersion

timestamp: Option<u64>

payload: Vec<u8>

metadata: Vec<u8>

Implementations

impl EAppend

pub fn parser<'a>() -> impl Parser<FrameStream<'a>, Output = EAppend> + 'a

Trait Implementations

impl Clone for EAppend

fn clone(&self) -> EAppend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EAppend

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

Formats the value using the given formatter.

impl Default for EAppend

fn default() -> EAppend

Returns the “default value” for a type.

impl HandleRequest for EAppend

type Error = String

type Ok = EAppendResp

async fn handle_request( self, conn: &mut Conn, ) -> Result<Option<Self::Ok>, Self::Error>

fn handle_request_failable( self, conn: &mut Conn, ) -> impl Future<Output = Result<Option<BytesFrame>, Error>> + Send