Method createTopic

pj_datastore/src/engine.cpp:121–124

// ---------------------------------------------------------------------------

Expected<TopicId> DataEngine::createTopic(DatasetId dataset_id, TopicDescriptor descriptor, TopicId requested_id) {
  std::unique_lock<std::recursive_mutex> lock(impl_->mutex_);
  return createTopicLocked(dataset_id, std::move(descriptor), requested_id);
}

Expected<TopicId> DataEngine::createTopicLocked(
    DatasetId dataset_id, TopicDescriptor descriptor, TopicId requested_id) {