()
| 166 | |
| 167 | #[test] |
| 168 | fn commit_kv_timeseries() { |
| 169 | let (mut core, mut tx, mut rx, _dir) = make_core(); |
| 170 | let ilp = "temp,host=s1 value=1.0 1000000000\n"; |
| 171 | |
| 172 | let resp = send_raw( |
| 173 | &mut core, |
| 174 | &mut tx, |
| 175 | &mut rx, |
| 176 | PhysicalPlan::Meta(MetaOp::TransactionBatch { |
| 177 | plans: vec![kv_put(b"kt1", b"val"), timeseries_ingest("temp", ilp)], |
| 178 | }), |
| 179 | ); |
| 180 | assert_eq!(resp.status, Status::Ok); |
| 181 | let r = send_raw(&mut core, &mut tx, &mut rx, kv_get(b"kt1")); |
| 182 | assert_eq!(&*r.payload, b"val"); |
| 183 | assert_ts_count(&mut core, &mut tx, &mut rx, "temp", 1); |
| 184 | } |
| 185 | |
| 186 | #[test] |
| 187 | fn rollback_kv_then_timeseries_fail() { |
nothing calls this directly
no test coverage detected