diff --git a/pkg/nodeconfigs/node_value_thresholds.go b/pkg/nodeconfigs/node_value_thresholds.go index cd4e90e..ec4edff 100644 --- a/pkg/nodeconfigs/node_value_thresholds.go +++ b/pkg/nodeconfigs/node_value_thresholds.go @@ -7,16 +7,17 @@ import "github.com/iwind/TeaGo/maps" type IPAddressThresholdItem = string const ( - IPAddressThresholdItemNodeAvgRequests IPAddressThresholdItem = "nodeAvgRequests" // 个 - IPAddressThresholdItemNodeAvgTrafficOut IPAddressThresholdItem = "nodeAvgTrafficOut" // 节点下行流量 M - IPAddressThresholdItemNodeAvgTrafficIn IPAddressThresholdItem = "nodeAvgTrafficIn" // 节点上行流量 M - IPAddressThresholdItemGroupAvgRequests IPAddressThresholdItem = "groupAvgRequests" // 个 - IPAddressThresholdItemGroupAvgTrafficIn IPAddressThresholdItem = "groupAvgTrafficIn" // 分组上行流量 M - IPAddressThresholdItemGroupAvgTrafficOut IPAddressThresholdItem = "groupAvgTrafficOut" // 分组下行流量 M - IPAddressThresholdItemClusterAvgRequests IPAddressThresholdItem = "clusterAvgRequests" // 个 - IPAddressThresholdItemClusterAvgTrafficIn IPAddressThresholdItem = "clusterAvgTrafficIn" // 集群上行流量 M - IPAddressThresholdItemClusterAvgTrafficOut IPAddressThresholdItem = "clusterAvgTrafficOut" // 集群下行流量 M - IPAddressThresholdItemConnectivity IPAddressThresholdItem = "connectivity" // 0-100 + IPAddressThresholdItemNodeAvgRequests IPAddressThresholdItem = "nodeAvgRequests" // 个 + IPAddressThresholdItemNodeAvgTrafficOut IPAddressThresholdItem = "nodeAvgTrafficOut" // 节点下行流量 M + IPAddressThresholdItemNodeAvgTrafficIn IPAddressThresholdItem = "nodeAvgTrafficIn" // 节点上行流量 M + IPAddressThresholdItemNodeHealthCheckFailed IPAddressThresholdItem = "nodeHealthCheckFailed" // 节点健康检查失败 + IPAddressThresholdItemGroupAvgRequests IPAddressThresholdItem = "groupAvgRequests" // 个 + IPAddressThresholdItemGroupAvgTrafficIn IPAddressThresholdItem = "groupAvgTrafficIn" // 分组上行流量 M + IPAddressThresholdItemGroupAvgTrafficOut IPAddressThresholdItem = "groupAvgTrafficOut" // 分组下行流量 M + IPAddressThresholdItemClusterAvgRequests IPAddressThresholdItem = "clusterAvgRequests" // 个 + IPAddressThresholdItemClusterAvgTrafficIn IPAddressThresholdItem = "clusterAvgTrafficIn" // 集群上行流量 M + IPAddressThresholdItemClusterAvgTrafficOut IPAddressThresholdItem = "clusterAvgTrafficOut" // 集群下行流量 M + IPAddressThresholdItemConnectivity IPAddressThresholdItem = "connectivity" // 0-100 ) // FindAllIPAddressThresholdItems IP相关阈值项目 @@ -40,6 +41,12 @@ func FindAllIPAddressThresholdItems() []maps.Map { "description": "当前节点在单位时间内接收的上行流量。", "unit": "M", }, + { + "name": "节点健康检查失败", + "code": IPAddressThresholdItemNodeHealthCheckFailed, + "description": "当前节点健康检查失败", + "unit": "", + }, { "name": "IP连通性", diff --git a/pkg/serverconfigs/server_address_group.go b/pkg/serverconfigs/server_address_group.go index f848af7..77c4f2e 100644 --- a/pkg/serverconfigs/server_address_group.go +++ b/pkg/serverconfigs/server_address_group.go @@ -177,6 +177,7 @@ func (this *ServerAddressGroup) MatchServerName(serverName string) *ServerConfig this.cacheLocker.Lock() // 限制缓存的最大尺寸,防止内存耗尽 + // TODO 清理20%比较老的数据 if this.countCacheDomains < 1_000_000 { domainMap, ok := this.cacheDomainMap[prefix] if ok {