mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-24 20:24:09 +00:00
move api.Probe timeout default to central defaults
This commit is contained in:
parent
6f84bdaba8
commit
4ba8ecd1fb
@ -75,5 +75,10 @@ func init() {
|
|||||||
obj.DNSPolicy = DNSClusterFirst
|
obj.DNSPolicy = DNSClusterFirst
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
func(obj *LivenessProbe) {
|
||||||
|
if obj.TimeoutSeconds == 0 {
|
||||||
|
obj.TimeoutSeconds = 1
|
||||||
|
}
|
||||||
|
},
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
@ -75,5 +75,10 @@ func init() {
|
|||||||
obj.DNSPolicy = DNSClusterFirst
|
obj.DNSPolicy = DNSClusterFirst
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
func(obj *LivenessProbe) {
|
||||||
|
if obj.TimeoutSeconds == 0 {
|
||||||
|
obj.TimeoutSeconds = 1
|
||||||
|
}
|
||||||
|
},
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
@ -70,5 +70,10 @@ func init() {
|
|||||||
obj.DNSPolicy = DNSClusterFirst
|
obj.DNSPolicy = DNSClusterFirst
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
func(obj *Probe) {
|
||||||
|
if obj.TimeoutSeconds == 0 {
|
||||||
|
obj.TimeoutSeconds = 1
|
||||||
|
}
|
||||||
|
},
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
@ -36,10 +36,7 @@ import (
|
|||||||
"github.com/golang/glog"
|
"github.com/golang/glog"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const maxProbeRetries = 3
|
||||||
defaultProbeTimeout = 1 * time.Second
|
|
||||||
maxProbeRetries = 3
|
|
||||||
)
|
|
||||||
|
|
||||||
// probeContainer executes the given probe on a container and returns the result.
|
// probeContainer executes the given probe on a container and returns the result.
|
||||||
// If the probe is nil this returns Success. If the probe's initial delay has not passed
|
// If the probe is nil this returns Success. If the probe's initial delay has not passed
|
||||||
@ -71,11 +68,7 @@ func (kl *Kubelet) probeContainer(p *api.Probe,
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (kl *Kubelet) runProbe(p *api.Probe, podFullName string, podUID types.UID, status api.PodStatus, container api.Container) (probe.Result, error) {
|
func (kl *Kubelet) runProbe(p *api.Probe, podFullName string, podUID types.UID, status api.PodStatus, container api.Container) (probe.Result, error) {
|
||||||
timeout := defaultProbeTimeout
|
timeout := time.Duration(p.TimeoutSeconds) * time.Second
|
||||||
secs := p.TimeoutSeconds
|
|
||||||
if secs > 0 {
|
|
||||||
timeout = time.Duration(secs) * time.Second
|
|
||||||
}
|
|
||||||
if p.Exec != nil {
|
if p.Exec != nil {
|
||||||
return kl.prober.exec.Probe(kl.newExecInContainer(podFullName, podUID, container))
|
return kl.prober.exec.Probe(kl.newExecInContainer(podFullName, podUID, container))
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user