kubernetes/staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics.go

var etcdRequestLatency …

var etcdRequestCounts …

var etcdRequestErrorCounts …

var objectCounts …

var dbTotalSize …

var storageSizeDescription …

var storageMonitor …

var etcdEventsReceivedCounts …

var etcdBookmarkCounts …

var etcdLeaseObjectCounts …

var listStorageCount …

var listStorageNumFetched …

var listStorageNumSelectorEvals …

var listStorageNumReturned …

var decodeErrorCounts …

var registerMetrics …

// Register all metrics.
func Register() { … }

// UpdateObjectCount sets the apiserver_storage_object_counts metric.
func UpdateObjectCount(resourcePrefix string, count int64) { … }

// RecordEtcdRequest updates and sets the etcd_request_duration_seconds,
// etcd_request_total, etcd_request_errors_total metrics.
func RecordEtcdRequest(verb, resource string, err error, startTime time.Time) { … }

// RecordEtcdEvent updated the etcd_events_received_total metric.
func RecordEtcdEvent(resource string) { … }

// RecordEtcdBookmark updates the etcd_bookmark_counts metric.
func RecordEtcdBookmark(resource string) { … }

// RecordDecodeError sets the storage_decode_errors metrics.
func RecordDecodeError(resource string) { … }

// Reset resets the etcd_request_duration_seconds metric.
func Reset() { … }

var sinceInSeconds …

// UpdateEtcdDbSize sets the etcd_db_total_size_in_bytes metric.
// Deprecated: Metric etcd_db_total_size_in_bytes will be replaced with apiserver_storage_size_bytes
func UpdateEtcdDbSize(ep string, size int64) { … }

// SetStorageMonitorGetter sets monitor getter to allow monitoring etcd stats.
func SetStorageMonitorGetter(getter func() ([]Monitor, error)) { … }

// UpdateLeaseObjectCount sets the etcd_lease_object_counts metric.
func UpdateLeaseObjectCount(count int64) { … }

// RecordListEtcd3Metrics notes various metrics of the cost to serve a LIST request
func RecordStorageListMetrics(resource string, numFetched, numEvald, numReturned int) { … }

type Monitor …

type StorageMetrics …

type monitorCollector …

func (m *monitorCollector) setGetter(monitorGetter func() ([]Monitor, error)) { … }

func (m *monitorCollector) getGetter() func() ([]Monitor, error) { … }

// DescribeWithStability implements compbasemetrics.StableColletor
func (c *monitorCollector) DescribeWithStability(ch chan<- *compbasemetrics.Desc) { … }

// CollectWithStability implements compbasemetrics.StableColletor
func (c *monitorCollector) CollectWithStability(ch chan<- compbasemetrics.Metric) { … }