- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for RecordEtcdBookmark (0.42 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics.go
// RecordEtcdEvent updated the etcd_events_received_total metric. func RecordEtcdEvent(resource string) { etcdEventsReceivedCounts.WithLabelValues(resource).Inc() } // RecordEtcdBookmark updates the etcd_bookmark_counts metric. func RecordEtcdBookmark(resource string) { etcdBookmarkCounts.WithLabelValues(resource).Inc() } // RecordDecodeError sets the storage_decode_errors metrics. func RecordDecodeError(resource string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 21:15:32 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
logWatchChannelErr(err) wc.sendError(err) return } if wres.IsProgressNotify() { wc.sendEvent(progressNotifyEvent(wres.Header.GetRevision())) metrics.RecordEtcdBookmark(wc.watcher.groupResource.String()) continue } for _, e := range wres.Events { metrics.RecordEtcdEvent(wc.watcher.groupResource.String()) parsedEvent, err := parseEvent(e) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0)