接收客户端订阅Ranktable请求。服务端为每一个任务分配一个消息队列,并侦听消息队列是否存在待发送的消息,若存在则通过gRPC stream发送给客户端。
rpc SubscribeRankTable(ClientInfo) returns (stream RankTableStream) {}
参数 |
类型(protobuf定义) |
说明 |
---|---|---|
ClientInfo |
message ClientInfo{ string jobId = 1; string role = 2; } |
ClientInfo.jobId:任务ID。 ClientInfo.role:客户端角色。 |
返回值 |
类型(protobuf定义) |
说明 |
---|---|---|
Stream |
grpc stream |
该接口返回gRPC stream(返回值的具体数据结构基于客户端选择的编程语言)。 客户端可以调用stream的Receive方法(具体方法名基于客户端选择的编程语言)接收服务端推送的数据。 |
RankTableStream |
message RankTableStream { string jobId = 1; string rankTable = 2; } |
RankTableStream.jobId:任务ID。 RankTableStream. rankTable:RankTable信息 |