Method BuildTopicScaleString

phxqueue/scheduler/schedulermgr.cpp:575–587

}

comm::RetCode SchedulerMgr::BuildTopicScaleString(const TopicData &topic_data, string &s) {
    for (auto &&consumer_addr2info_kv : topic_data.consumer_addr2info_map) {
        if (1000 < s.size()) {
            s += "...";

            return comm::RetCode::RET_OK;
        }
        s += comm::utils::EncodedAddrToIPString(consumer_addr2info_kv.first) + ":";
        s += to_string(consumer_addr2info_kv.second.weight) + ";";
    }

    return comm::RetCode::RET_OK;
}

Mode SchedulerMgr::GetMode(const int topic_id, TopicData &topic_data, const uint64_t now) {
    Mode mode{Mode::Dynamic};