Skip to main content

insert

nodedb_lite::query::columnar_ops::writes

Function insert 

Source 
pub async fn insert<S: StorageEngine>(
    engine: &LiteQueryEngine<S>,
    collection: &str,
    params: InsertParams<'_>,
) -> Result<(QueryResult, Vec<Vec<Value>>), LiteError>
Expand description

Insert rows into a columnar collection.

Decodes the payload per format (“json”, “msgpack”, “ilp”), respects intent (Insert / InsertIfAbsent / InsertUnique / Put), and assigns surrogates from the provided list falling back to 0 when the list is shorter than the row count.

Returns the QueryResult together with the column-ordered rows that were actually written to the memtable. The caller is responsible for calling engine.columnar.enqueue_outbound from an async context to durably queue those rows for replication to Origin.