- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RecordKeyIDFromStatus (0.24 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/metrics/metrics.go
KeyIDHashLastTimestampSeconds.WithLabelValues(transformationType, providerName, keyIDHash, apiServerIDHash).SetToCurrentTime() } // RecordKeyIDFromStatus records last time in seconds when a KeyID was returned by the Status RPC call. func RecordKeyIDFromStatus(providerName, keyID, apiServerID string) { lockRecordKeyIDStatus.Lock() defer lockRecordKeyIDStatus.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 09 22:31:32 UTC 2023 - 12K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/metrics/metrics_test.go
apiServerID := rand.String(32) key := metricLabels{ providerName: rand.String(32), keyIDHash: getHash(keyID), apiServerIDHash: getHash(apiServerID), } RecordKeyIDFromStatus(key.providerName, keyID, apiServerID) }() } wg.Wait() validMetrics := 0 metricFamilies, err := legacyregistry.DefaultGatherer.Gather() if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 09 22:31:32 UTC 2023 - 31.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
errs = append(errs, fmt.Errorf("got invalid KMSv2 KeyID hash %q: %w", envelopekmsv2.GetHashIfNotEmpty(response.KeyID), err)) } else { envelopemetrics.RecordKeyIDFromStatus(h.name, response.KeyID, h.apiServerID) // unconditionally append as we filter out nil errors below errs = append(errs, h.rotateDEKOnKeyIDChange(ctx, response.KeyID, string(uuid.NewUUID()))) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0)