(
array: &str,
coord_x: i64,
v: f64,
schema_hlc: nodedb_array::sync::hlc::Hlc,
ms: u64,
)
| 33 | } |
| 34 | |
| 35 | fn put_delta( |
| 36 | array: &str, |
| 37 | coord_x: i64, |
| 38 | v: f64, |
| 39 | schema_hlc: nodedb_array::sync::hlc::Hlc, |
| 40 | ms: u64, |
| 41 | ) -> ArrayDeltaMsg { |
| 42 | let op = ArrayOp { |
| 43 | header: ArrayOpHeader { |
| 44 | array: array.to_string(), |
| 45 | hlc: hlc(ms, 1), |
| 46 | schema_hlc, |
| 47 | valid_from_ms: 0, |
| 48 | valid_until_ms: -1, |
| 49 | system_from_ms: ms as i64, |
| 50 | }, |
| 51 | kind: ArrayOpKind::Put, |
| 52 | coord: vec![CoordValue::Int64(coord_x)], |
| 53 | attrs: Some(vec![CellValue::Float64(v)]), |
| 54 | }; |
| 55 | let payload = op_codec::encode_op(&op).expect("encode op"); |
| 56 | ArrayDeltaMsg { |
| 57 | array: array.to_string(), |
| 58 | op_payload: payload, |
| 59 | } |
| 60 | } |
| 61 | |
| 62 | fn make_inbound(shared: &Arc<SharedState>) -> OriginArrayInbound { |
| 63 | let engine = Arc::new(OriginApplyEngine::new( |
no test coverage detected