Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for RecordInvalidKeyIDFromStatus (0.39 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/metrics/metrics.go

    	KeyIDHashStatusLastTimestampSeconds.WithLabelValues(providerName, keyIDHash, apiServerIDHash).SetToCurrentTime()
    }
    
    func RecordInvalidKeyIDFromStatus(providerName, errCode string) {
    	InvalidKeyIDFromStatusTotal.WithLabelValues(providerName, errCode).Inc()
    }
    
    func RecordArrival(transformationType string, start time.Time) {
    	switch transformationType {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 09 22:31:32 UTC 2023
    - 12K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/metrics/metrics_test.go

    		t.Run(tt.desc, func(t *testing.T) {
    			defer InvalidKeyIDFromStatusTotal.Reset()
    			var wg sync.WaitGroup
    			for i := 0; i < tt.count; i++ {
    				wg.Add(1)
    				go func() {
    					defer wg.Done()
    					RecordInvalidKeyIDFromStatus(tt.providerName, errCode)
    				}()
    			}
    			wg.Wait()
    
    			if err := testutil.GatherAndCompare(legacyregistry.DefaultGatherer, strings.NewReader(tt.want), tt.metrics...); 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)
  3. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go

    		}
    	}
    
    	if errCode, err := envelopekmsv2.ValidateKeyID(response.KeyID); err != nil {
    		envelopemetrics.RecordInvalidKeyIDFromStatus(h.name, string(errCode))
    		errs = append(errs, fmt.Errorf("got invalid KMSv2 KeyID hash %q: %w", envelopekmsv2.GetHashIfNotEmpty(response.KeyID), err))
    	} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top