metrics

Documentation

Index

• Constants
• func IsGKEComponentVersionAvailable() bool
• func UpdateRequestMetadataFromDisk(ctx context.Context, disk *gce.CloudDisk)
• func UpdateRequestMetadataFromParams(ctx context.Context, params common.DiskParameters)
• type MetricInterceptor
  • func (m *MetricInterceptor) UnaryInterceptor() grpc.UnaryServerInterceptor
• 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) RecordOperationErrorMetrics(fullMethodName string, operationErr error, diskType string, ...)
  • func (mm *MetricsManager) RegisterPDCSIMetric()
  • func (mm *MetricsManager) ResetMetrics()
• type RequestMetadata
  • func MetadataFromContext(ctx context.Context) *RequestMetadata
• type Server

Constants

const (
	DefaultDiskTypeForMetric         = "unknownDiskType"
	DefaultEnableConfidentialCompute = "unknownConfidentialMode"
	DefaultEnableStoragePools        = "unknownStoragePools"
)

Functions

func IsGKEComponentVersionAvailable

func IsGKEComponentVersionAvailable() bool

func UpdateRequestMetadataFromDisk

func UpdateRequestMetadataFromDisk(ctx context.Context, disk *gce.CloudDisk)

func UpdateRequestMetadataFromParams

func UpdateRequestMetadataFromParams(ctx context.Context, params common.DiskParameters)

Types

type MetricInterceptor

type MetricInterceptor struct {
	MetricsManager *MetricsManager
}

func (*MetricInterceptor) UnaryInterceptor

func (m *MetricInterceptor) UnaryInterceptor() grpc.UnaryServerInterceptor

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) RecordOperationErrorMetrics

func (mm *MetricsManager) RecordOperationErrorMetrics(
	fullMethodName string,
	operationErr error,
	diskType string,
	enableConfidentialStorage string,
	enableStoragePools string)

func (*MetricsManager) RegisterPDCSIMetric

func (mm *MetricsManager) RegisterPDCSIMetric()

func (*MetricsManager) ResetMetrics

func (mm *MetricsManager) ResetMetrics()

Test-only method used for resetting metric counts.

type RequestMetadata

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

RequestMetadata represents metadata about a gRPC CSI request

func MetadataFromContext

func MetadataFromContext(ctx context.Context) *RequestMetadata

MetadataFromContext returns a mutable from a request context

type Server

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

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