Function put_delta

nodedb-cluster-tests/tests/array_raft_replication.rs:43–68

(
    array: &str,
    coord_x: i64,
    v: f64,
    schema_hlc: nodedb_array::sync::hlc::Hlc,
    ms: u64,
)

}

fn put_delta(
    array: &str,
    coord_x: i64,
    v: f64,
    schema_hlc: nodedb_array::sync::hlc::Hlc,
    ms: u64,
) -> ArrayDeltaMsg {
    let op = ArrayOp {
        header: ArrayOpHeader {
            array: array.to_string(),
            hlc: hlc(ms, 1),
            schema_hlc,
            valid_from_ms: 0,
            valid_until_ms: -1,
            system_from_ms: ms as i64,
        },
        kind: ArrayOpKind::Put,
        coord: vec![CoordValue::Int64(coord_x)],
        attrs: Some(vec![CellValue::Float64(v)]),
    };
    let payload = op_codec::encode_op(&op).expect("encode op");
    ArrayDeltaMsg {
        array: array.to_string(),
        op_payload: payload,
    }
}

fn make_inbound(shared: &Arc<SharedState>) -> OriginArrayInbound {
    let engine = Arc::new(OriginApplyEngine::new(