SubscribeFaultMsgSignal
功能说明
接收客户端订阅故障信息请求。服务端为每一个任务分配一个消息队列,并侦听消息队列是否存在待发送的消息,若存在则通过grpc stream发送给客户端。
函数原型
rpc SubscribeFaultMsgSignal(ClientInfo) returns (stream FaultMsgSignal){}
输入参数说明
参数 |
类型(Protobuf定义) |
说明 |
---|---|---|
ClientInfo |
message ClientInfo{ string jobId = 1; string role = 2; } |
ClientInfo.jobId:任务ID。 ClientInfo.role:客户端角色。 |
返回值说明
返回值 |
类型(Protobuf定义) |
说明 |
---|---|---|
Stream |
grpc stream |
该接口返回gRPC stream(返回值的具体数据结构基于客户端选择的编程语言)。 客户端可以调用stream的Receive方法(具体方法名基于客户端选择的编程语言)接收服务端推送的数据。 |
发送数据说明
参数 |
类型(Protobuf定义) |
说明 |
---|---|---|
FaultMsgSignal |
message FaultMsgSignal{ string uuid = 1; string jobId = 2; string signalType = 3; repeated NodeFaultInfo nodeFaultInfo = 4; } message NodeFaultInfo{ string nodeName = 1; string nodeIP = 2; string nodeSN = 3; string faultLevel = 4; repeated DeviceFaultInfo faultDevice = 5; } message DeviceFaultInfo{ string deviceId = 1; string deviceType = 2; repeated string faultCodes = 3; string faultLevel = 4; repeated string faultType = 5; repeated string faultReason = 6; } |
FaultMsgSignal.uuid:消息ID FaultMsgSignal.jobId:任务ID FaultMsgSignal.signalType:消息类型,“fault”代表故障发生,“normal”代表无故障或故障恢复 FaultMsgSignal.nodeFaultInfo:节点故障信息 NodeFaultInfo.nodeName:故障节点名称NodeFaultInfo.nodeIP:节点IP NodeFaultInfo.nodeSN:节点SN号 NodeFaultInfo.faultLevel:故障类型,包括“Healthy”、“SubHealthy”和“UnHealthy”,设置为DeviceFaultInfo.faultLevel中最严重的级别 NodeFaultInfo.faultDevice:设备故障信息 DeviceFaultInfo.deviceId:设备ID DeviceFaultInfo.deviceType:设备类型名,包括“Node”、“NPU”、“Storage”、“CPU”、“Network”等 DeviceFaultInfo.faultCodes:故障码列表 DeviceFaultInfo.faultLevel:故障类型,包括“Healthy”、“SubHealthy”和“UnHealthy”,严重级别依次递增 DeviceFaultInfo.faultType:故障子系统类型,预留字段 DeviceFaultInfo.faultReason:故障原因,预留字段 |