Method createDataSource

pj_datastore/src/plugin_data_host.cpp:352–362

  }

  [[nodiscard]] bool createDataSource(std::string_view name, DataSourceHandle* out_source) {
    auto engine_locks = lockWriteEngines(engine, secondary_engine);
    auto id_or = engine.createDataset(DatasetDescriptor{.source_name = std::string(name), .time_domain_id = 0});
    if (!id_or.has_value()) {
      setError(id_or.error());
      return false;
    }
    *out_source = DataSourceHandle{.id = *id_or};
    last_error.clear();
    return true;
  }

  // Idempotent re-mirror of a topic onto the secondary engine. Called on
  // every successful ensureTopic path (including cache hits) so a previously