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

const namespace …

const subsystem …

const FromStorageLabel …

const ToStorageLabel …

type metricLabels …

var lockLastFromStorage …

var lockLastToStorage …

var lockRecordKeyID …

var lockRecordKeyIDStatus …

var lastFromStorage …

var lastToStorage …

var keyIDHashTotalMetricLabels …

var keyIDHashStatusLastTimestampSecondsMetricLabels …

var cacheSize …

var dekCacheFillPercent …

var dekCacheInterArrivals …

var KMSOperationsLatencyMetric …

var KeyIDHashTotal …

var KeyIDHashLastTimestampSeconds …

var KeyIDHashStatusLastTimestampSeconds …

var InvalidKeyIDFromStatusTotal …

var DekSourceCacheSize …

var registerMetricsFunc …

var hashPool …

func registerLRUMetrics() { … }

func RegisterMetrics() { … }

// 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) { … }

// RecordKeyIDFromStatus records last time in seconds when a KeyID was returned by the Status RPC call.
func RecordKeyIDFromStatus(providerName, keyID, apiServerID string) { … }

func RecordInvalidKeyIDFromStatus(providerName, errCode string) { … }

func RecordArrival(transformationType string, start time.Time) { … }

func RecordDekCacheFillPercent(percent float64) { … }

func RecordDekSourceCacheSize(providerName string, size int) { … }

// RecordKMSOperationLatency records the latency of KMS operation.
func RecordKMSOperationLatency(providerName, methodName string, duration time.Duration, err error) { … }

type gRPCError …

func getErrorCode(err error) string { … }

func getHash(data string) string { … }

func addLabelToCache(c *lru.Cache, transformationType, providerName, keyID, apiServerID string) (string, string) { … }