metrics

Documentation

Index

• Constants
• func IsGKEComponentVersionAvailable() bool
• type MetricsManager
  • func NewMetricsManager() *MetricsManager
  • func (mm *MetricsManager) EmitGKEComponentVersion() error
  • func (mm *MetricsManager) GetRegistry() metrics.KubeRegistry
  • func (mm *MetricsManager) InitializeHttpHandler(address, path string)
  • func (mm *MetricsManager) RecordKubeAPIMetrics(opErr error, resourceType, opType, opSource string, opDuration time.Duration)
  • func (mm *MetricsManager) RecordLockReleaseMetrics(opErr error)
  • func (mm *MetricsManager) RecordOperationMetrics(opErr error, methodName string, filestoreMode string, opDuration time.Duration)
  • func (mm *MetricsManager) RegisterKubeAPIDurationMetric()
  • func (mm *MetricsManager) RegisterLockReleaseCountnMetric()
  • func (mm *MetricsManager) RegisterOperationSecondsMetric()
• type Server

Constants

const (
	ConfigMapResourceType = "configmap"
	NodeResourceType      = "node"

	GetOpType    = "get"
	CreateOpType = "create"
	UpdateOpType = "update"
	ListOpType   = "list"

	NodeStageOpSource   = "node_stage_volume"
	NodeUnstageOpSource = "node_unstage_volume"
	ReconcilerOpSource  = "lock_release_reconciler"
)

Functions

func IsGKEComponentVersionAvailable

func IsGKEComponentVersionAvailable() bool

Types

type MetricsManager

type MetricsManager struct {
	// contains filtered or unexported fields
}

func NewMetricsManager

func NewMetricsManager() *MetricsManager

func (*MetricsManager) EmitGKEComponentVersion

func (mm *MetricsManager) EmitGKEComponentVersion() error

func (*MetricsManager) GetRegistry

func (mm *MetricsManager) GetRegistry() metrics.KubeRegistry

func (*MetricsManager) InitializeHttpHandler

func (mm *MetricsManager) InitializeHttpHandler(address, path string)

InitializeHttpHandler sets up a server and creates a handler for metrics.

func (*MetricsManager) RecordKubeAPIMetrics

func (mm *MetricsManager) RecordKubeAPIMetrics(opErr error, resourceType, opType, opSource string, opDuration time.Duration)

func (*MetricsManager) RecordLockReleaseMetrics

func (mm *MetricsManager) RecordLockReleaseMetrics(opErr error)

func (*MetricsManager) RecordOperationMetrics

func (mm *MetricsManager) RecordOperationMetrics(opErr error, methodName string, filestoreMode string, opDuration time.Duration)

func (*MetricsManager) RegisterKubeAPIDurationMetric

func (mm *MetricsManager) RegisterKubeAPIDurationMetric()

func (*MetricsManager) RegisterLockReleaseCountnMetric

func (mm *MetricsManager) RegisterLockReleaseCountnMetric()

func (*MetricsManager) RegisterOperationSecondsMetric

func (mm *MetricsManager) RegisterOperationSecondsMetric()

type Server

type Server interface {
	Handle(pattern string, handler http.Handler)
}

Server represents any type that could serve HTTP requests for the metrics endpoint.