Struct Upsert 

pub struct Upsert {
    pub table: String,
    pub key: String,
    pub row: Row,
}

Version-gated upsert command.

version is compared against the existing row’s version column (if any). The store writes only when the row is absent or the existing version is strictly less than this value. That makes projectors idempotent: replaying the same event sequence twice — or receiving the same event twice through at-least-once delivery — converges to the same final state.

Fields

table: String

Logical table / collection name (e.g. "users_view").

key: String

Primary key value (string-typed; backends serialize as needed).

row: Row

Full row payload as a JSON object. Must include the primary key field and a version field so the store can apply the version gate.

Implementations

impl Upsert

pub fn new(table: impl Into<String>, key: impl Into<String>, row: Row) -> Self

Trait Implementations

impl Clone for Upsert

fn clone(&self) -> Upsert

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Upsert

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

Formats the value using the given formatter.