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

实现健康检查配置、立即执行健康检查

Browse Source
This commit is contained in:
GoEdgeLab
2020-10-17 21:15:37 +08:00
parent 13dae71699
commit dfc5b07f6b
7 changed files with 951 additions and 281 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -2,8 +2,10 @@ syntax = "proto3";
option go_package = "./pb";
package pb;
import "model_node_cluster.proto";
import "model_api_node.proto";
import "model_node.proto";
import "rpc_messages.proto";
service NodeClusterService {
@@ -33,6 +35,15 @@ service NodeClusterService {
// 列出单页集群
rpc listEnabledNodeClusters (ListEnabledNodeClustersRequest) returns (ListEnabledNodeClustersResponse);
// 查找集群的健康检查配置
rpc findNodeClusterHealthCheckConfig (FindNodeClusterHealthCheckConfigRequest) returns (FindNodeClusterHealthCheckConfigResponse);
// 修改集群健康检查设置
rpc updateNodeClusterHealthCheck (UpdateNodeClusterHealthCheckRequest) returns (RPCUpdateSuccess);
// 执行健康检查
rpc executeNodeClusterHealthCheck (ExecuteNodeClusterHealthCheckRequest) returns (ExecuteNodeClusterHealthCheckResponse);
}
// 获取所有集群的信息
@@ -117,4 +128,36 @@ message ListEnabledNodeClustersRequest {
message ListEnabledNodeClustersResponse {
repeated NodeCluster clusters = 1;
}
// 查找集群的健康检查配置
message FindNodeClusterHealthCheckConfigRequest {
int64 clusterId = 1;
}
message FindNodeClusterHealthCheckConfigResponse {
bytes healthCheckConfig = 1;
}
// 修改集群健康检查设置
message UpdateNodeClusterHealthCheckRequest {
int64 clusterId = 1;
bytes healthCheckJSON = 2;
}
// 执行健康检查
message ExecuteNodeClusterHealthCheckRequest {
int64 clusterId = 1;
}
message ExecuteNodeClusterHealthCheckResponse {
repeated Result results = 1;
message Result {
Node node = 1;
string nodeAddr = 2;
bool isOk = 3;
string error = 4;
float costMs = 5;
}
}