- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RecordKeyID (0.25 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/metrics/metrics.go
legacyregistry.MustRegister(InvalidKeyIDFromStatusTotal) legacyregistry.MustRegister(KMSOperationsLatencyMetric) }) } // RecordKeyID records total count and last time in seconds when a KeyID was used for TransformFromStorage and TransformToStorage operations func RecordKeyID(transformationType, providerName, keyID, apiServerID string) { lockRecordKeyID.Lock() defer lockRecordKeyID.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
}, } KeyIDHashTotal.Reset() cacheSize = 2 RegisterMetrics() registerLRUMetrics() for _, tt := range testCases { t.Run(tt.desc, func(t *testing.T) { RecordKeyID(tt.transformationType, tt.providerName, tt.keyID, tt.apiServerID) // We are not resetting the metric here as each test is not independent in order to validate the behavior
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/storage/value/encrypt/envelope/kmsv2/envelope.go
} span.AddEvent("DEK decryption succeeded") transformer, err = t.addTransformerForDecryption(encryptedObjectCacheKey, key, useSeed) if err != nil { return nil, false, err } } metrics.RecordKeyID(metrics.FromStorageLabel, t.providerName, encryptedObject.KeyID, t.apiServerID) span.AddEvent("About to decrypt data using DEK") out, stale, err := transformer.TransformFromStorage(ctx, encryptedObject.EncryptedData, dataCtx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 00:23:50 UTC 2023 - 18.7K bytes - Viewed (0)