- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RecordDecodeError (0.24 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
klog.Errorf("failed to update object version: %v", err) } return obj, nil } // recordDecodeError record decode error split by object type. func recordDecodeError(resource string, key string) { metrics.RecordDecodeError(resource) klog.V(4).Infof("Decoding %s \"%s\" failed", resource, key) } func notFound(key string) clientv3.Cmp {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics.go
} // 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) { decodeErrorCounts.WithLabelValues(resource).Inc() } // Reset resets the etcd_request_duration_seconds metric. func Reset() { etcdRequestLatency.Reset()
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/metrics/metrics_test.go
# TYPE apiserver_storage_decode_errors_total counter apiserver_storage_decode_errors_total{resource="pods"} 1 `, }, } for _, test := range testCases { t.Run(test.desc, func(t *testing.T) { RecordDecodeError(test.resource) if err := testutil.GatherAndCompare(registry, strings.NewReader(test.want), testedMetrics); err != nil { t.Fatal(err) } }) } } func TestRecordEtcdRequest(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 21:15:32 UTC 2024 - 10.2K bytes - Viewed (0)