Function HandleClientGetFollower

src/cmd/fedb.cc:4318–4363

}

void HandleClientGetFollower(const std::vector<std::string>& parts,
                             ::fedb::client::TabletClient* client) {
    if (parts.size() < 3) {
        std::cout << "Bad get follower format" << std::endl;
        return;
    }
    uint32_t tid = 0;
    uint32_t pid = 0;
    try {
        tid = boost::lexical_cast<uint32_t>(parts[1]);
        pid = boost::lexical_cast<uint32_t>(parts[2]);
    } catch (std::exception const& e) {
        std::cout << "Invalid args" << std::endl;
        return;
    }
    std::map<std::string, uint64_t> info_map;
    uint64_t offset = 0;
    std::string msg;
    if (!client->GetTableFollower(tid, pid, offset, info_map, msg)) {
        std::cout << "get failed. msg: " << msg << std::endl;
        return;
    }
    std::vector<std::string> header;
    header.push_back("#");
    header.push_back("tid");
    header.push_back("pid");
    header.push_back("leader_offset");
    header.push_back("follower");
    header.push_back("offset");
    ::baidu::common::TPrinter tp(header.size(), FLAGS_max_col_display_length);

    tp.AddRow(header);
    int idx = 0;
    for (const auto& kv : info_map) {
        std::vector<std::string> row;
        row.push_back(std::to_string(idx));
        idx++;
        row.push_back(std::to_string(tid));
        row.push_back(std::to_string(pid));
        row.push_back(std::to_string(offset));
        row.push_back(kv.first);
        row.push_back(std::to_string(kv.second));
        tp.AddRow(row);
    }
    tp.Print(true);
}

void HandleClientCount(const std::vector<std::string>& parts,
                       ::fedb::client::TabletClient* client) {