TRKJ/EdgeCommon
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeCommon.git synced 2025-11-04 13:10:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

节点IP阈值增加节点健康检查失败

Browse Source
This commit is contained in:
刘祥超
2021-11-18 14:30:58 +08:00
parent 422b71d9b1
commit 886969f4ee
2 changed files with 18 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
pkg/nodeconfigs/node_value_thresholds.go
View File

@@ -7,16 +7,17 @@ import "github.com/iwind/TeaGo/maps"
type IPAddressThresholdItem = string type IPAddressThresholdItem = string
const ( const (
IPAddressThresholdItemNodeAvgRequests IPAddressThresholdItem = "nodeAvgRequests" // 个 IPAddressThresholdItemNodeAvgRequests IPAddressThresholdItem = "nodeAvgRequests" // 个
IPAddressThresholdItemNodeAvgTrafficOut IPAddressThresholdItem = "nodeAvgTrafficOut" // 节点下行流量 M IPAddressThresholdItemNodeAvgTrafficOut IPAddressThresholdItem = "nodeAvgTrafficOut" // 节点下行流量 M
IPAddressThresholdItemNodeAvgTrafficIn IPAddressThresholdItem = "nodeAvgTrafficIn" // 节点上行流量 M IPAddressThresholdItemNodeAvgTrafficIn IPAddressThresholdItem = "nodeAvgTrafficIn" // 节点上行流量 M
IPAddressThresholdItemGroupAvgRequests IPAddressThresholdItem = "groupAvgRequests" // 个 IPAddressThresholdItemNodeHealthCheckFailed IPAddressThresholdItem = "nodeHealthCheckFailed" // 节点健康检查失败
IPAddressThresholdItemGroupAvgTrafficIn IPAddressThresholdItem = "groupAvgTrafficIn" // 分组上行流量 M IPAddressThresholdItemGroupAvgRequests IPAddressThresholdItem = "groupAvgRequests" // 个
IPAddressThresholdItemGroupAvgTrafficOut IPAddressThresholdItem = "groupAvgTrafficOut" // 分组下行流量 M IPAddressThresholdItemGroupAvgTrafficIn IPAddressThresholdItem = "groupAvgTrafficIn" // 分组上行流量 M
IPAddressThresholdItemClusterAvgRequests IPAddressThresholdItem = "clusterAvgRequests" // 个 IPAddressThresholdItemGroupAvgTrafficOut IPAddressThresholdItem = "groupAvgTrafficOut" // 分组下行流量 M
IPAddressThresholdItemClusterAvgTrafficIn IPAddressThresholdItem = "clusterAvgTrafficIn" // 集群上行流量 M IPAddressThresholdItemClusterAvgRequests IPAddressThresholdItem = "clusterAvgRequests" // 个
IPAddressThresholdItemClusterAvgTrafficOut IPAddressThresholdItem = "clusterAvgTrafficOut" // 集群下行流量 M IPAddressThresholdItemClusterAvgTrafficIn IPAddressThresholdItem = "clusterAvgTrafficIn" // 集群上行流量 M
IPAddressThresholdItemConnectivity IPAddressThresholdItem = "connectivity" // 0-100 IPAddressThresholdItemClusterAvgTrafficOut IPAddressThresholdItem = "clusterAvgTrafficOut" // 集群下行流量 M
IPAddressThresholdItemConnectivity IPAddressThresholdItem = "connectivity" // 0-100
) )
// FindAllIPAddressThresholdItems IP相关阈值项目 // FindAllIPAddressThresholdItems IP相关阈值项目
@@ -40,6 +41,12 @@ func FindAllIPAddressThresholdItems() []maps.Map {
"description": "当前节点在单位时间内接收的上行流量。", "description": "当前节点在单位时间内接收的上行流量。",
"unit": "M", "unit": "M",
}, },
{
"name": "节点健康检查失败",
"code": IPAddressThresholdItemNodeHealthCheckFailed,
"description": "当前节点健康检查失败",
"unit": "",
},
{ {
"name": "IP连通性", "name": "IP连通性",

1
pkg/serverconfigs/server_address_group.go
View File

@@ -177,6 +177,7 @@ func (this *ServerAddressGroup) MatchServerName(serverName string) *ServerConfig
this.cacheLocker.Lock() this.cacheLocker.Lock()
// 限制缓存的最大尺寸，防止内存耗尽 // 限制缓存的最大尺寸，防止内存耗尽
// TODO 清理20%比较老的数据
if this.countCacheDomains < 1_000_000 { if this.countCacheDomains < 1_000_000 {
domainMap, ok := this.cacheDomainMap[prefix] domainMap, ok := this.cacheDomainMap[prefix]
if ok { if ok {