zrhoffman commented on code in PR #7302:
URL: https://github.com/apache/trafficcontrol/pull/7302#discussion_r1134499743
##########
traffic_monitor/datareq/crstate.go:
##########
@@ -21,6 +21,7 @@ package datareq
import (
"fmt"
+ "github.com/apache/trafficcontrol/traffic_monitor/health"
Review Comment:
Imports starting with `github.com/apache/trafficcontrol` should be grouped
separately
##########
traffic_monitor/cache/stats_over_http.go:
##########
@@ -56,6 +56,7 @@ const LOADAVG_SHIFT = 65536
func init() {
// AddStatsType("stats_over_http", statsParse, statsPrecompute)
Review Comment:
Can this commented line be removed?
##########
traffic_monitor/datareq/crstate.go:
##########
@@ -109,11 +110,11 @@ func updateStatusSameIpServers(localStates
peer.CRStatesThreadsafe, toData todat
allIsAvailable := true
for partner, _ := range toDataC.SameIpServers[cache] {
if partnerState, ok :=
localStatesC.Caches[partner]; ok {
- // a partner host is reported but is
marked down for too high traffic or load
+ // a partner host is reported but is
marked down for exceeding a threshold
// this host also needs to be marked
down to divert all traffic for their
// common ip
if
strings.Contains(partnerState.Status, string(tc.CacheStatusReported)) &&
-
strings.Contains(partnerState.Status, "too high") {
+
strings.Contains(partnerState.Status, fmt.Sprint(health.TooHigh)) {
Review Comment:
`fmt.Sprint(health.TooHigh)` can be `health.TooHigh.String()`
##########
traffic_monitor/todata/todata.go:
##########
@@ -187,7 +187,9 @@ func (d TODataThreadsafe) Update(to
towrap.TrafficOpsSessionThreadsafe, cdn stri
return fmt.Errorf("getting server types from monitoring config:
%v", err)
}
- newTOData.SameIpServers = getSameIPServers(mc)
+ if val, ok := mc.Config["tm.sameipservers.control"]; ok &&
fmt.Sprint(val) == "true" {
Review Comment:
> `fmt.Sprint(val)`
Use `val.(string)`
##########
traffic_monitor/health/cache.go:
##########
@@ -46,6 +46,26 @@ const AvailableStr = "available"
// available to serve traffic.
const UnavailableStr = "unavailable"
+type Threshold int
+
+const (
+ NotEqual Threshold = iota
+ TooLow
+ TooHigh
+)
Review Comment:
Why not define a `Threshold` as a string?
```go
type Threshold string
const (
NotEqual Threshold = "too low"
TooLow = "too low"
TooHigh = "too high"
)
```
That would make converting to a string easier later.
##########
traffic_monitor/todata/todata.go:
##########
@@ -187,7 +187,9 @@ func (d TODataThreadsafe) Update(to
towrap.TrafficOpsSessionThreadsafe, cdn stri
return fmt.Errorf("getting server types from monitoring config:
%v", err)
}
- newTOData.SameIpServers = getSameIPServers(mc)
+ if val, ok := mc.Config["tm.sameipservers.control"]; ok &&
fmt.Sprint(val) == "true" {
Review Comment:
This is a new parameter. would you mind adding it to
https://traffic-control-cdn.readthedocs.io/en/latest/admin/traffic_monitor.html?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
