metrics

Documentation

Index

• type Metrics
  • func NewMetrics(enabled bool) *Metrics
  • func (m *Metrics) GetStats() map[string]interface{}
  • func (m *Metrics) RecordConnection(active bool)
  • func (m *Metrics) RecordError(errorType string)
  • func (m *Metrics) RecordRequest(success bool, duration time.Duration)
  • func (m *Metrics) StartMetricsServer(ctx context.Context, port int) error

Types

type Metrics

type Metrics struct {

	// 请求统计
	TotalRequests      int64
	SuccessfulRequests int64
	FailedRequests     int64

	// 响应时间统计
	ResponseTimes []time.Duration

	// 错误统计
	ErrorCounts map[string]int64

	// 连接统计
	ActiveConnections int64
	TotalConnections  int64
	// contains filtered or unexported fields
}

Metrics 指标收集器

func NewMetrics

func NewMetrics(enabled bool) *Metrics

NewMetrics 创建新的指标收集器

func (*Metrics) GetStats

func (m *Metrics) GetStats() map[string]interface{}

GetStats 获取统计信息

func (*Metrics) RecordConnection

func (m *Metrics) RecordConnection(active bool)

RecordConnection 记录连接

func (*Metrics) RecordError

func (m *Metrics) RecordError(errorType string)

RecordError 记录错误

func (*Metrics) RecordRequest

func (m *Metrics) RecordRequest(success bool, duration time.Duration)

RecordRequest 记录请求

func (*Metrics) StartMetricsServer

func (m *Metrics) StartMetricsServer(ctx context.Context, port int) error

StartMetricsServer 启动指标服务器