TRKJ/EdgeCommon
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeCommon.git synced 2025-12-16 05:46:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化消息通知相关代码

Browse Source
This commit is contained in:
刘祥超
2023-10-14 17:15:52 +08:00
parent f949e31c0f
commit a7ae7ea2db
11 changed files with 403 additions and 141 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
pkg/rpc/protos/service_message_receiver.proto
View File

@@ -14,6 +14,9 @@ service MessageReceiverService {
// 查找接收者
rpc findAllEnabledMessageReceivers (FindAllEnabledMessageReceiversRequest) returns (FindAllEnabledMessageReceiversResponse);
// 根据接收人查找关联的接收者
rpc findAllEnabledMessageReceiversWithMessageRecipientId (FindAllEnabledMessageReceiversWithMessageRecipientIdRequest) returns (FindAllEnabledMessageReceiversWithMessageRecipientIdResponse);
// 删除接收者
rpc deleteMessageReceiver (DeleteMessageReceiverRequest) returns (RPCSuccess);
@@ -28,7 +31,7 @@ message UpdateMessageReceiversRequest {
int64 nodeId = 2;
int64 serverId = 3;
bytes paramsJSON = 5;
map<string, RecipientOptions> recipientOptions = 6; // type => options
map<string, RecipientOptions> recipientOptions = 6; // type => options，type为recipient或者group
message RecipientOption {
int64 messageRecipientId = 1;
@@ -42,25 +45,34 @@ message UpdateMessageReceiversRequest {
// 查找接收者
message FindAllEnabledMessageReceiversRequest {
string role = 4;
int64 nodeClusterId = 1;
int64 nodeId = 2;
int64 serverId = 3;
string role = 4; // 集群角色：node 或 dns
int64 nodeClusterId = 1; // 集群ID
int64 nodeId = 2; // 节点ID
int64 serverId = 3; // 网站ID
}
message FindAllEnabledMessageReceiversResponse {
repeated MessageReceiver messageReceivers = 1;
}
// 根据接收人查找关联的接收者
message FindAllEnabledMessageReceiversWithMessageRecipientIdRequest {
int64 messageRecipientId = 1; // 关联的接收人ID
}
message FindAllEnabledMessageReceiversWithMessageRecipientIdResponse {
repeated MessageReceiver messageReceivers = 1;
}
// 删除接收者
message DeleteMessageReceiverRequest {
int64 messageReceiverId = 1;
int64 messageReceiverId = 1; // 接收者ID
}
// 计算接收者数量
message CountAllEnabledMessageReceiversRequest {
string role = 4;
int64 nodeClusterId = 1;
int64 nodeId = 2;
int64 serverId = 3;
string role = 4; // 集群角色：node 或 dns
int64 nodeClusterId = 1; // 集群ID
int64 nodeId = 2; // 节点ID
int64 serverId = 3; // 网站ID
}