- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for updateMetric (1.28 sec)
-
internal/kms/kms.go
dek, err := k.conn.GenerateKey(ctx, req) k.updateMetrics(err, time.Since(start)) return dek, err } // Decrypt decrypts a ciphertext using the master key req.Name. // It returns ErrKeyNotFound if the key does not exist. func (k *KMS) Decrypt(ctx context.Context, req *DecryptRequest) ([]byte, error) { start := time.Now() plaintext, err := k.conn.Decrypt(ctx, req) k.updateMetrics(err, time.Since(start))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
} func (pm *basicManager) UpdatePod(pod *v1.Pod) { pm.lock.Lock() defer pm.lock.Unlock() pm.updatePodsInternal(pod) } // updateMetrics updates the metrics surfaced by the pod manager. // oldPod or newPod may be nil to signify creation or deletion. func updateMetrics(oldPod, newPod *v1.Pod) { var numEC int if oldPod != nil { numEC -= len(oldPod.Spec.EphemeralContainers) } if newPod != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache.go
logger.Error(err, "ExpirePod failed", "podKey", key, "pod", klog.KObj(ps.pod)) } } } } // updateMetrics updates cache size metric values for pods, assumed pods, and nodes func (cache *cacheImpl) updateMetrics() { metrics.CacheSize.WithLabelValues("assumed_pods").Set(float64(len(cache.assumedPods))) metrics.CacheSize.WithLabelValues("pods").Set(float64(len(cache.podStates)))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
defer ticker.Stop() for { select { case <-ticker.C: push := s.globalPushContext() model.LastPushMutex.Lock() if model.LastPushStatus != push { model.LastPushStatus = push push.UpdateMetrics() out, _ := model.LastPushStatus.StatusJSON() if string(out) != "{}" { log.Infof("Push Status: %s", string(out)) } } model.LastPushMutex.Unlock() case <-stopCh: return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0)