Struct RowPushMsg 

pub struct RowPushMsg {
    pub collection: String,
    pub document_id: String,
    pub payload: Vec<u8>,
    pub op: RowOp,
    pub lsn: u64,
    pub peer_id: u64,
    pub sequence: u64,
}

Row post-image push (server → client, 0x15).

Origin sends this for writes that originated on the server — SQL DML, or DDL-managed system rows such as retention policies and alerts — where there is no client-authored CRDT operation to replicate. The peer applies it as a row upsert or delete against its local state.

Deliberately NOT DeltaPushMsg: that message is client → server and its delta field is Loro update bytes. Carrying a MessagePack post-image in it would leave the receiver unable to tell the two encodings apart, and the operation (upsert vs delete) would have to be inferred from an empty payload rather than stated.

Fields

collection: String

Collection the row belongs to.

document_id: String

Row / document ID.

payload: Vec<u8>

MessagePack-encoded row post-image. Empty for RowOp::Delete.

op: RowOp

Whether the row was written or removed.

lsn: u64

Origin-assigned WAL LSN for the write, when known (0 otherwise).

peer_id: u64

Originating peer / node ID.

sequence: u64

Per-collection monotonic sequence, for ordering diagnostics.

Trait Implementations

impl Clone for RowPushMsg

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RowPushMsg

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RowPushMsg

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for RowPushMsg

fn read<R: Read<'__msgpack_de>>(reader: &mut R) -> Result<Self, Error>

where Self: Sized,

Reads the MessagePack representation of this value from the provided reader.

impl Serialize for RowPushMsg

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToMessagePack for RowPushMsg

fn write<W: Write>(&self, writer: &mut W) -> Result<(), Error>

Writes the MessagePack representation of this value into the provided writer.

fn size_hint(&self) -> Option<TrustedSizeHint>

Returns a trusted upper bound for the number of bytes written by the next call to Self::write, or None when it cannot be determined cheaply.

fn max_size() -> Option<TrustedSizeHint>

Returns a trusted upper bound valid for every value of this type.

fn write_slice<W>(values: &[Self], writer: &mut W) -> Result<(), Error>

where W: Write, Self: Sized,

Writes the MessagePack representation of a slice of values into the provided writer.