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();
54 std::string m_serverAddress;
56 std::string m_clientAddress;
58 std::unique_ptr<grpc::Server> m_server;
60 std::unique_ptr<NodeInstance::Stub> m_nodeInstanceService;
62 std::function<void(CongestionReason,
const std::string &)>
63 m_congestionReportCallback;