Struct EMAppend 

pub struct EMAppend {
    pub partition_key: Uuid,
    pub events: Vec<Event>,
}

Append multiple events to streams in a single transaction.

Syntax

EMAPPEND <partition_key> <stream_id1> <event_name1> [EVENT_ID <event_id1>] [EXPECTED_VERSION <version1>] [TIMESTAMP <timestamp>] [PAYLOAD <payload1>] [METADATA <metadata1>] [<stream_id2> <event_name2> ...]

Parameters

• partition_key: UUID that determines which partition all events will be written to
• For each event:
  • 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)
  • expected_version (optional): Expected stream version (number, “any”, “exists”, “empty”)
  • timestamp (optional): Event timestamp in milliseconds
  • payload (optional): Event payload data
  • metadata (optional): Event metadata

Example

EMAPPEND 550e8400-e29b-41d4-a716-446655440000 stream1 EventA PAYLOAD '{"data":"value1"}' stream2 EventB PAYLOAD '{"data":"value2"}'

Note: All events are appended atomically in a single transaction.

Fields

partition_key: Uuid

events: Vec<Event>

Implementations

impl EMAppend

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

Trait Implementations

impl Clone for EMAppend

fn clone(&self) -> EMAppend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EMAppend

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

Formats the value using the given formatter.

impl Default for EMAppend

fn default() -> EMAppend

Returns the “default value” for a type.

impl HandleRequest for EMAppend

type Error = String

type Ok = EMAppendResp

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

impl PartialEq for EMAppend

fn eq(&self, other: &EMAppend) -> 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 Eq for EMAppend

impl StructuralPartialEq for EMAppend