SubscribeNotifyExecStressTest

Description

Receives the online stress testing subscription request from the client. The server allocates a message queue to each job and monitors whether the message queue contains messages to be transmitted. If yes, the server transmits the messages to the client through the gRPC stream.

Prototype

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

Input Parameters

Parameter	Type (Defined by Protobuf)	Description
ClientInfo	message ClientInfo{ string jobId = 1; string role = 2; }	ClientInfo.jobId: job ID ClientInfo.role: client role

Parameter

Type (Defined by Protobuf)

Description

ClientInfo

message ClientInfo{

string jobId = 1;

string role = 2;

}

ClientInfo.jobId: job ID

ClientInfo.role: client role

Data to Be Sent

Parameter	Type (Defined by Protobuf)	Description
StressTestRankParams	message StressTestRankParams { map<string, StressOpList> stressParam = 1; string jobId = 2; }	StressTestRankParams.stressParam: key indicates the global rank ID of the node where online stress testing is to be performed, and value indicates the corresponding operation. 0 indicates AIC stress testing, and 1 indicates P2P stress testing. StressTestRankParams.jobId: job ID

Parameter

Type (Defined by Protobuf)

Description

StressTestRankParams

message StressTestRankParams {

map<string, StressOpList> stressParam = 1;

string jobId = 2;

}

StressTestRankParams.stressParam: key indicates the global rank ID of the node where online stress testing is to be performed, and value indicates the corresponding operation. 0 indicates AIC stress testing, and 1 indicates P2P stress testing.

StressTestRankParams.jobId: job ID

Return Value

Parameter	Type (Defined by Protobuf)	Description
stream	gRPC stream	This API returns a gRPC stream. (The data structure of the return value is based on the programming language selected by the client.) The client can call the stream's Receive method (the actual name is determined by the client's programming language) to receive data pushed by the server.

Parent topic: Online Stress Testing APIs