TRKJ/EdgeCommon
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeCommon.git synced 2025-11-18 16:30:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

通知媒介增加任务队列查看功能

Browse Source
This commit is contained in:
刘祥超
2021-08-24 14:23:21 +08:00
parent 66af31330e
commit ae85d39275
2 changed files with 537 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
pkg/rpc/protos/service_message_task.proto
View File

@@ -22,6 +22,12 @@ service MessageTaskService {
// 读取消息任务状态
rpc findEnabledMessageTask (FindEnabledMessageTaskRequest) returns (FindEnabledMessageTaskResponse);
// 计算某个状态的消息任务数量
rpc countMessageTasksWithStatus(CountMessageTasksWithStatusRequest) returns (RPCCountResponse);
// 根据状态列出某页任务
rpc listMessageTasksWithStatus(ListMessageTasksWithStatusRequest) returns (ListMessageTasksWithStatusResponse);
}
// 创建消息任务
@@ -67,3 +73,33 @@ message FindEnabledMessageTaskRequest {
message FindEnabledMessageTaskResponse {
MessageTask messageTask = 1;
}
// 计算某个状态的消息任务数量
message CountMessageTasksWithStatusRequest {
Status status = 1;
enum Status {
MessageTaskStatusNone = 0;
MessageTaskStatusSending = 1;
MessageTaskStatusSuccess = 2;
MessageTaskStatusFailed = 3;
}
}
// 根据状态列出某页任务
message ListMessageTasksWithStatusRequest {
Status status = 1;
int64 offset = 2;
int64 size = 3;
enum Status {
MessageTaskStatusNone = 0;
MessageTaskStatusSending = 1;
MessageTaskStatusSuccess = 2;
MessageTaskStatusFailed = 3;
}
}
message ListMessageTasksWithStatusResponse {
repeated MessageTask messageTasks = 1;
}