mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-23 02:26:52 +00:00
replace time.Now().Sub with time.Since
This commit is contained in:
parent
c7c89f8c61
commit
0205215425
@ -135,7 +135,7 @@ func (h *kmsPluginProbe) Check() error {
|
|||||||
h.l.Lock()
|
h.l.Lock()
|
||||||
defer h.l.Unlock()
|
defer h.l.Unlock()
|
||||||
|
|
||||||
if (time.Now().Sub(h.lastResponse.received)) < kmsPluginHealthzTTL {
|
if (time.Since(h.lastResponse.received)) < kmsPluginHealthzTTL {
|
||||||
return h.lastResponse.err
|
return h.lastResponse.err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -108,7 +108,7 @@ func BuildAndRegisterAggregator(downloader *Downloader, delegationTarget server.
|
|||||||
// Build initial spec to serve.
|
// Build initial spec to serve.
|
||||||
klog.V(2).Infof("Building initial OpenAPI spec")
|
klog.V(2).Infof("Building initial OpenAPI spec")
|
||||||
defer func(start time.Time) {
|
defer func(start time.Time) {
|
||||||
duration := time.Now().Sub(start)
|
duration := time.Since(start)
|
||||||
klog.V(2).Infof("Finished initial OpenAPI spec generation after %v", duration)
|
klog.V(2).Infof("Finished initial OpenAPI spec generation after %v", duration)
|
||||||
|
|
||||||
regenerationCounter.With(map[string]string{"apiservice": "*", "reason": "startup"})
|
regenerationCounter.With(map[string]string{"apiservice": "*", "reason": "startup"})
|
||||||
@ -222,7 +222,7 @@ func (s *specAggregator) tryUpdatingServiceSpecs(specInfo *openAPISpecInfo) erro
|
|||||||
}
|
}
|
||||||
klog.V(2).Infof("Updating OpenAPI spec because %s is updated", specInfo.apiService.Name)
|
klog.V(2).Infof("Updating OpenAPI spec because %s is updated", specInfo.apiService.Name)
|
||||||
defer func(start time.Time) {
|
defer func(start time.Time) {
|
||||||
duration := time.Now().Sub(start)
|
duration := time.Since(start)
|
||||||
klog.V(2).Infof("Finished OpenAPI spec generation after %v", duration)
|
klog.V(2).Infof("Finished OpenAPI spec generation after %v", duration)
|
||||||
|
|
||||||
reason := "add"
|
reason := "add"
|
||||||
@ -254,7 +254,7 @@ func (s *specAggregator) tryDeleteServiceSpecs(apiServiceName string) error {
|
|||||||
delete(s.openAPISpecs, apiServiceName)
|
delete(s.openAPISpecs, apiServiceName)
|
||||||
klog.V(2).Infof("Updating OpenAPI spec because %s is removed", apiServiceName)
|
klog.V(2).Infof("Updating OpenAPI spec because %s is removed", apiServiceName)
|
||||||
defer func(start time.Time) {
|
defer func(start time.Time) {
|
||||||
duration := time.Now().Sub(start)
|
duration := time.Since(start)
|
||||||
klog.V(2).Infof("Finished OpenAPI spec generation after %v", duration)
|
klog.V(2).Infof("Finished OpenAPI spec generation after %v", duration)
|
||||||
|
|
||||||
regenerationCounter.With(map[string]string{"apiservice": apiServiceName, "reason": "delete"})
|
regenerationCounter.With(map[string]string{"apiservice": apiServiceName, "reason": "delete"})
|
||||||
|
Loading…
Reference in New Issue
Block a user