Function buildFlushFixture

pj_datastore/tests/engine_integration_test.cpp:1128–1139

};

FlushFixture buildFlushFixture(const std::string& topic = "scalar/topic") {
  FlushFixture f;
  f.src_dataset = *f.src.createDataset(DatasetDescriptor{.source_name = "src", .time_domain_id = 0});
  f.dst_dataset = *f.dst.createDataset(DatasetDescriptor{.source_name = "dst", .time_domain_id = 0});

  DataWriter sw = f.src.createWriter();
  f.src_handle = *sw.registerScalarSeries(f.src_dataset, topic, NumericType::kFloat64);

  DataWriter dw = f.dst.createWriter();
  f.dst_handle = *dw.registerScalarSeries(f.dst_dataset, topic, NumericType::kFloat64);
  return f;
}

void writeScalars(DataEngine& engine, ScalarSeriesHandle handle, Timestamp start, std::size_t count) {
  DataWriter w = engine.createWriter();