Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for latencyBuckets (0.05 sec)

  1. internal/kms/kms.go

    }
    
    // Metrics returns a current snapshot of the KMS metrics.
    func (k *KMS) Metrics(ctx context.Context) (*Metrics, error) {
    	latency := make(map[time.Duration]uint64, len(k.latencyBuckets))
    	for i, b := range k.latencyBuckets {
    		latency[b] = k.latency[i].Load()
    	}
    
    	return &Metrics{
    		ReqOK:   k.reqOK.Load(),
    		ReqErr:  k.reqErr.Load(),
    		ReqFail: k.reqFail.Load(),
    		Latency: latency,
    	}, nil
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Apr 24 15:33:57 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  2. internal/kms/config.go

    			DefaultKey: env.Get(EnvKMSDefaultKey, ""),
    			conn: &kmsConn{
    				enclave:    env.Get(EnvKMSEnclave, ""),
    				defaultKey: env.Get(EnvKMSDefaultKey, ""),
    				client:     client,
    			},
    			latencyBuckets: defaultLatencyBuckets,
    			latency:        make([]atomic.Uint64, len(defaultLatencyBuckets)),
    		}, nil
    	case lookup(EnvKESEndpoint):
    		rawEndpoint := env.Get(EnvKESEndpoint, "")
    		if rawEndpoint == "" {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15K bytes
    - Viewed (0)
  3. internal/kms/secret-key.go

    		return nil, errors.New("kms: invalid key length " + strconv.Itoa(len(key)))
    	}
    	return &KMS{
    		Type:       Builtin,
    		DefaultKey: keyID,
    		conn: secretKey{
    			keyID: keyID,
    			key:   key,
    		},
    		latencyBuckets: defaultLatencyBuckets,
    		latency:        make([]atomic.Uint64, len(defaultLatencyBuckets)),
    	}, nil
    }
    
    // secretKey is a KMS implementation that derives new DEKs
    // from a single key.
    type secretKey struct {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Apr 21 16:23:51 UTC 2025
    - 8.4K bytes
    - Viewed (0)
Back to top