()
| 122 | |
| 123 | #[test] |
| 124 | fn commit_kv_columnar() { |
| 125 | let (mut core, mut tx, mut rx, _dir) = make_core(); |
| 126 | |
| 127 | let resp = send_raw( |
| 128 | &mut core, |
| 129 | &mut tx, |
| 130 | &mut rx, |
| 131 | PhysicalPlan::Meta(MetaOp::TransactionBatch { |
| 132 | plans: vec![kv_put(b"kc1", b"val"), columnar_insert("metrics", "r1", 10)], |
| 133 | }), |
| 134 | ); |
| 135 | assert_eq!(resp.status, Status::Ok); |
| 136 | let r = send_raw(&mut core, &mut tx, &mut rx, kv_get(b"kc1")); |
| 137 | assert_eq!(&*r.payload, b"val"); |
| 138 | } |
| 139 | |
| 140 | #[test] |
| 141 | fn rollback_kv_then_columnar_fail() { |