Method GetStoreConfig

phxqueue/config/globalconfig.cpp:193–205

}

comm::RetCode GlobalConfig::GetStoreConfig(const int topic_id, shared_ptr<const StoreConfig> &store_config) {
    store_config = nullptr;

    auto &&it = impl_->topic_id2store_config.find(topic_id);
    if (it == impl_->topic_id2store_config.end()) {
        NeedRebuild();
        return comm::RetCode::RET_ERR_RANGE_TOPIC;
    }
    if (!it->second) return comm::RetCode::RET_ERR_RANGE_TOPIC;
    it->second->Load();
    store_config = it->second;
    return comm::RetCode::RET_OK;
}

comm::RetCode GlobalConfig::GetSchedulerConfig(const int topic_id, shared_ptr<const SchedulerConfig> &scheduler_config) {
    scheduler_config = nullptr;