35 const std::string &clientAddress,
36 std::function<
void(CongestionReason,
const std::string &)>
37 congestionReportCallback);
41 void receiveCongestionReport(CongestionReason congestionReason,
42 const std::string &edgeName);
44 void repartition(
const std::string &edgeName, uint32_t lowerPartitionBound,
45 uint32_t upperPartitionBound);
47 std::unordered_map<std::string, EdgeStats> queryEdgeStats();
50 void runGrpcServer(
const std::string &address);
52 void runGrpcClient(
const std::string &address);
55 const std::string &m_serverAddress;
57 const std::string &m_clientAddress;
59 std::unique_ptr<grpc::Server> m_server;
61 std::unique_ptr<NodeInstance::Stub> m_nodeInstanceService;
63 std::function<void(CongestionReason,
const std::string &)>
64 m_congestionReportCallback;