SubscribeNotifyExecStressTest

接收客户端订阅在线压测信号请求。服务端为每一个任务分配一个消息队列，并侦听消息队列是否存在待发送的消息，若存在则通过gRPC stream发送给客户端。

rpc SubscribeNotifyExecStressTest(ClientInfo) returns (stream StressTestRankParams) {}

参数	类型（Protobuf定义）	说明
ClientInfo	message ClientInfo{ string jobId = 1; string role = 2; }	ClientInfo.jobId：任务ID。 ClientInfo.role：客户端角色。

参数

类型（Protobuf定义）

说明

ClientInfo

message ClientInfo{

string jobId = 1;

string role = 2;

}

ClientInfo.jobId：任务ID。

ClientInfo.role：客户端角色。

参数	类型（Protobuf定义）	说明
StressTestRankParams	message StressTestRankParams { map<string, StressOpList> stressParam = 1; string jobId = 2; }	StressTestRankParams.stressParam：key为该节点上要执行压测的global RankID，value为对应的压测操作，0表示“aic”压测；1表示“p2p”压测。 StressTestRankParams.jobId：任务ID。

参数

类型（Protobuf定义）

说明

StressTestRankParams

message StressTestRankParams {

map<string, StressOpList> stressParam = 1;

string jobId = 2;

}

StressTestRankParams.stressParam：key为该节点上要执行压测的global RankID，value为对应的压测操作，0表示“aic”压测；1表示“p2p”压测。

StressTestRankParams.jobId：任务ID。

参数	类型（Protobuf定义）	说明
stream	grpc stream	该接口返回gRPC stream（返回值的具体数据结构基于客户端选择的编程语言）。客户端可以调用stream的Receive方法（具体方法名基于客户端选择的编程语言）接收服务端推送的数据。

父主题： 在线压测接口