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

实现基础的阈值设置

Browse Source
This commit is contained in:
GoEdgeLab
2021-05-04 21:02:21 +08:00
parent 0314fa9d43
commit 479920e3c7
44 changed files with 3958 additions and 1808 deletions
Download Patch File Download Diff File Expand all files Collapse all files

0
pkg/rpc/protos/models/message_media.proto → pkg/rpc/protos/models/model_message_media.proto
View File

2
pkg/rpc/protos/models/message_media_instance.proto → pkg/rpc/protos/models/model_message_media_instance.proto
View File

@@ -3,7 +3,7 @@ option go_package = "./pb";
package pb;
import "models/message_media.proto";
import "models/model_message_media.proto";
message MessageMediaInstance {
int64 id = 1;

0
pkg/rpc/protos/models/message_node_value.proto → pkg/rpc/protos/models/model_message_node_value.proto
View File

4
pkg/rpc/protos/models/message_receiver.proto → pkg/rpc/protos/models/model_message_receiver.proto
View File

@@ -3,8 +3,8 @@ option go_package = "./pb";
package pb;
import "models/message_recipient.proto";
import "models/message_recipient_group.proto";
import "models/model_message_recipient.proto";
import "models/model_message_recipient_group.proto";
message MessageReceiver {
int64 id = 1;

4
pkg/rpc/protos/models/message_recipient.proto → pkg/rpc/protos/models/model_message_recipient.proto
View File

@@ -4,8 +4,8 @@ option go_package = "./pb";
package pb;
import "models/model_admin.proto";
import "models/message_recipient_group.proto";
import "models/message_media_instance.proto";
import "models/model_message_recipient_group.proto";
import "models/model_message_media_instance.proto";
message MessageRecipient {
int64 id = 1;

0
pkg/rpc/protos/models/message_recipient_group.proto → pkg/rpc/protos/models/model_message_recipient_group.proto
View File

4
pkg/rpc/protos/models/message_task.proto → pkg/rpc/protos/models/model_message_task.proto
View File

@@ -3,8 +3,8 @@ option go_package = "./pb";
package pb;
import "models/message_recipient.proto";
import "models/message_media_instance.proto";
import "models/model_message_recipient.proto";
import "models/model_message_media_instance.proto";
message MessageTask {
int64 id = 1;

2
pkg/rpc/protos/models/message_task_log.proto → pkg/rpc/protos/models/model_message_task_log.proto
View File

@@ -3,7 +3,7 @@ option go_package = "./pb";
package pb;
import "models/message_task.proto";
import "models/model_message_task.proto";
// 消息任务日志
message MessageTaskLog {

19
pkg/rpc/protos/models/model_node_threshold.proto Normal file
View File

@@ -0,0 +1,19 @@
syntax = "proto3";
option go_package = "./pb";
package pb;
message NodeThreshold {
int64 id = 1;
int64 clusterId = 2;
int64 nodeId = 3;
string item = 4;
string param = 5;
string operator = 6;
bytes valueJSON = 7;
string message = 8;
int32 duration = 9;
string durationUnit = 10;
string sumMethod = 11;
bool isOn = 12;
}

2
pkg/rpc/protos/service_message_media.proto
View File

@@ -3,7 +3,7 @@ option go_package = "./pb";
package pb;
import "models/message_media.proto";
import "models/model_message_media.proto";
import "models/rpc_messages.proto";
// 消息媒介管理

2
pkg/rpc/protos/service_message_media_instance.proto
View File

@@ -3,7 +3,7 @@ option go_package = "./pb";
package pb;
import "models/message_media_instance.proto";
import "models/model_message_media_instance.proto";
import "models/rpc_messages.proto";
// 消息媒介实例

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

@@ -3,7 +3,7 @@ option go_package = "./pb";
package pb;
import "models/message_receiver.proto";
import "models/model_message_receiver.proto";
import "models/rpc_messages.proto";
// 消息对象接收者设置
@@ -12,10 +12,13 @@ service MessageReceiverService {
rpc updateMessageReceivers (UpdateMessageReceiversRequest) returns (RPCSuccess);
// 查找接收者
rpc findAllMessageReceivers (FindAllMessageReceiversRequest) returns (FindAllMessageReceiversResponse);
rpc findAllEnabledMessageReceivers (FindAllEnabledMessageReceiversRequest) returns (FindAllEnabledMessageReceiversResponse);
// 删除接收者
rpc deleteMessageReceiver (DeleteMessageReceiverRequest) returns (RPCSuccess);
// 计算接收者数量
rpc countAllEnabledMessageReceivers (CountAllEnabledMessageReceiversRequest) returns (RPCCountResponse);
}
// 修改接收者
@@ -37,17 +40,24 @@ message UpdateMessageReceiversRequest {
}
// 查找接收者
message FindAllMessageReceiversRequest {
message FindAllEnabledMessageReceiversRequest {
int64 nodeClusterId = 1;
int64 nodeId = 2;
int64 serverId = 3;
}
message FindAllMessageReceiversResponse {
message FindAllEnabledMessageReceiversResponse {
repeated MessageReceiver messageReceivers = 1;
}
// 删除接收者
message DeleteMessageReceiverRequest {
int64 messageReceiverId = 1;
}
// 计算接收者数量
message CountAllEnabledMessageReceiversRequest {
int64 nodeClusterId = 1;
int64 nodeId = 2;
int64 serverId = 3;
}

2
pkg/rpc/protos/service_message_recipient.proto
View File

@@ -3,7 +3,7 @@ option go_package = "./pb";
package pb;
import "models/message_recipient.proto";
import "models/model_message_recipient.proto";
import "models/rpc_messages.proto";
// 消息接收人

2
pkg/rpc/protos/service_message_recipient_group.proto
View File

@@ -3,7 +3,7 @@ option go_package = "./pb";
package pb;
import "models/message_recipient_group.proto";
import "models/model_message_recipient_group.proto";
import "models/rpc_messages.proto";
// 消息接收人分组

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

@@ -3,7 +3,7 @@ option go_package = "./pb";
package pb;
import "models/message_task.proto";
import "models/model_message_task.proto";
import "models/rpc_messages.proto";
// 消息发送任务服务

2
pkg/rpc/protos/service_message_task_log.proto
View File

@@ -3,7 +3,7 @@ option go_package = "./pb";
package pb;
import "models/message_task_log.proto";
import "models/model_message_task_log.proto";
import "models/rpc_messages.proto";
// 消息发送任务日志

2
pkg/rpc/protos/service_node_cluster.proto
View File

@@ -385,7 +385,7 @@ message CheckPortIsUsingInNodeClusterResponse {
bool isUsing = 1;
}
// 查找最近的集群
// 查找最近访问的集群
message FindLatestNodeClustersRequest {
int64 size = 1;
}

90
pkg/rpc/protos/service_node_threshold.proto Normal file
View File

@@ -0,0 +1,90 @@
syntax = "proto3";
option go_package = "./pb";
package pb;
import "models/rpc_messages.proto";
import "models/model_node_threshold.proto";
// 节点阈值服务
service NodeThresholdService {
// 创建阈值
rpc createNodeThreshold (CreateNodeThresholdRequest) returns (CreateNodeThresholdResponse);
// 修改阈值
rpc updateNodeThreshold (UpdateNodeThresholdRequest) returns (RPCSuccess);
// 删除阈值
rpc deleteNodeThreshold (DeleteNodeThresholdRequest) returns (RPCSuccess);
// 查询阈值
rpc findAllEnabledNodeThresholds (FindAllEnabledNodeThresholdsRequest) returns (FindAllEnabledNodeThresholdsResponse);
// 计算阈值数量
rpc countAllEnabledNodeThresholds (CountAllEnabledNodeThresholdsRequest) returns (RPCCountResponse);
// 查询单个阈值详情
rpc findEnabledNodeThreshold (FindEnabledNodeThresholdRequest) returns (FindEnabledNodeThresholdResponse);
}
// 创建阈值
message CreateNodeThresholdRequest {
int64 nodeClusterId = 1;
int64 nodeId = 2;
string item = 3;
string param = 4;
string operator = 5;
bytes valueJSON = 6;
string message = 7;
int32 duration = 8;
string durationUnit = 9;
string sumMethod = 10;
}
message CreateNodeThresholdResponse {
int64 nodeThresholdId = 1;
}
// 修改阈值
message UpdateNodeThresholdRequest {
int64 nodeThresholdId = 1;
string item = 2;
string param = 3;
string operator = 4;
bytes valueJSON = 5;
string message = 6;
int32 duration = 7;
string durationUnit = 8;
string sumMethod = 9;
bool isOn = 10;
}
// 删除阈值
message DeleteNodeThresholdRequest {
int64 nodeThresholdId = 1;
}
// 查询阈值
message FindAllEnabledNodeThresholdsRequest {
int64 nodeClusterId = 1;
int64 nodeId = 2;
}
message FindAllEnabledNodeThresholdsResponse {
repeated NodeThreshold nodeThresholds = 1;
}
// 计算阈值数量
message CountAllEnabledNodeThresholdsRequest {
int64 nodeClusterId = 1;
int64 nodeId = 2;
}
// 查询单个阈值详情
message FindEnabledNodeThresholdRequest {
int64 nodeThresholdId = 1;
}
message FindEnabledNodeThresholdResponse {
NodeThreshold nodeThreshold = 1;
}

2
pkg/rpc/protos/service_node_value.proto
View File

@@ -4,7 +4,7 @@ option go_package = "./pb";
package pb;
import "models/rpc_messages.proto";
import "models/message_node_value.proto";
import "models/model_message_node_value.proto";
// 节点指标数据服务
service NodeValueService {

12
pkg/rpc/protos/service_server.proto
View File

@@ -113,6 +113,9 @@ service ServerService {
// 检查域名是否已经存在
rpc checkServerNameDuplicationInNodeCluster (CheckServerNameDuplicationInNodeClusterRequest) returns (CheckServerNameDuplicationInNodeClusterResponse);
// 查找最近访问的服务
rpc findLatestServers (FindLatestServersRequest) returns (FindLatestServersResponse);
}
// 创建服务
@@ -444,4 +447,13 @@ message CheckServerNameDuplicationInNodeClusterRequest {
message CheckServerNameDuplicationInNodeClusterResponse {
repeated string duplicatedServerNames = 1;
}
// 查找最近访问的服务
message FindLatestServersRequest {
int64 size = 1;
}
message FindLatestServersResponse {
repeated Server servers = 1;
}