SubscribeRankTable

功能说明

接收客户端订阅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信息