File tree Expand file tree Collapse file tree 1 file changed +8
-9
lines changed
Expand file tree Collapse file tree 1 file changed +8
-9
lines changed Original file line number Diff line number Diff line change @@ -88,21 +88,20 @@ func (d dests) MarshalLogObject(enc zapcore.ObjectEncoder) error {
8888}
8989
9090const (
91- defaultProbeTimeout time.Duration = 300 * time .Millisecond
91+ defaultProbeTimeout time.Duration = 300 * time .Millisecond
9292 defaultProbeFrequency time.Duration = 200 * time .Millisecond
9393)
9494
9595var (
96- probeTimeout = func () time.Duration {
97- val := os .Getenv ("PROBE_TIMEOUT_MS" )
98- if ms , err := strconv .Atoi (val ); err == nil && ms > 0 {
99- return time .Duration (ms ) * time .Millisecond
100- }
101- return defaultProbeTimeout
102- }()
96+ probeTimeout = func () time.Duration {
97+ val := os .Getenv ("PROBE_TIMEOUT_MS" )
98+ if ms , err := strconv .Atoi (val ); err == nil && ms > 0 {
99+ return time .Duration (ms ) * time .Millisecond
100+ }
101+ return defaultProbeTimeout
102+ }()
103103)
104104
105-
106105// revisionWatcher watches the podIPs and ClusterIP of the service for a revision. It implements the logic
107106// to supply revisionDestsUpdate events on updateCh
108107type revisionWatcher struct {
You can’t perform that action at this time.
0 commit comments