metrics

package
v1.0.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 26, 2025 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Metrics

type Metrics struct {
	// Connection metrics
	ConnectionsActive int64
	ConnectionsTotal  int64
	ConnectionsFailed int64
	ConnectionsIdle   int64

	// Operation metrics
	OperationsTotal   int64
	OperationsSuccess int64
	OperationsFailed  int64

	// Performance metrics
	TotalLatencyMs int64
	MinLatencyMs   int64
	MaxLatencyMs   int64

	// Health status
	LastHealthCheck time.Time
	HealthStatus    string
	ErrorCount      int64
	LastError       string
	LastErrorTime   time.Time
	// contains filtered or unexported fields
}

Metrics represents a collection of operational metrics

func NewMetrics

func NewMetrics() *Metrics

NewMetrics creates a new metrics instance

func (*Metrics) DecrementConnectionsActive

func (m *Metrics) DecrementConnectionsActive()

DecrementConnectionsActive decrements active connections counter

func (*Metrics) GetAverageLatencyMs

func (m *Metrics) GetAverageLatencyMs() int64

GetAverageLatencyMs returns average latency in milliseconds

func (*Metrics) GetHealthStatus

func (m *Metrics) GetHealthStatus() string

GetHealthStatus returns current health status

func (*Metrics) GetSnapshot

func (m *Metrics) GetSnapshot() MetricsSnapshot

GetSnapshot returns a snapshot of current metrics

func (*Metrics) IncrementConnectionsActive

func (m *Metrics) IncrementConnectionsActive()

IncrementConnectionsActive increments active connections counter

func (*Metrics) IncrementConnectionsFailed

func (m *Metrics) IncrementConnectionsFailed()

IncrementConnectionsFailed increments failed connections counter

func (*Metrics) IncrementConnectionsTotal

func (m *Metrics) IncrementConnectionsTotal()

IncrementConnectionsTotal increments total connections counter

func (*Metrics) IncrementOperationsFailed

func (m *Metrics) IncrementOperationsFailed()

IncrementOperationsFailed increments failed operations counter

func (*Metrics) IncrementOperationsSuccess

func (m *Metrics) IncrementOperationsSuccess()

IncrementOperationsSuccess increments successful operations counter

func (*Metrics) IncrementOperationsTotal

func (m *Metrics) IncrementOperationsTotal()

IncrementOperationsTotal increments total operations counter

func (*Metrics) RecordError

func (m *Metrics) RecordError(err error)

RecordError records an error

func (*Metrics) RecordLatency

func (m *Metrics) RecordLatency(latencyMs int64)

RecordLatency records operation latency

func (*Metrics) Reset

func (m *Metrics) Reset()

Reset resets all metrics

func (*Metrics) SetConnectionsIdle

func (m *Metrics) SetConnectionsIdle(count int64)

SetConnectionsIdle sets idle connections count

func (*Metrics) UpdateHealthStatus

func (m *Metrics) UpdateHealthStatus(status string)

UpdateHealthStatus updates health status

type MetricsSnapshot

type MetricsSnapshot struct {
	ConnectionsActive int64     `json:"connections_active"`
	ConnectionsTotal  int64     `json:"connections_total"`
	ConnectionsFailed int64     `json:"connections_failed"`
	ConnectionsIdle   int64     `json:"connections_idle"`
	OperationsTotal   int64     `json:"operations_total"`
	OperationsSuccess int64     `json:"operations_success"`
	OperationsFailed  int64     `json:"operations_failed"`
	AverageLatencyMs  int64     `json:"average_latency_ms"`
	MinLatencyMs      int64     `json:"min_latency_ms"`
	MaxLatencyMs      int64     `json:"max_latency_ms"`
	HealthStatus      string    `json:"health_status"`
	LastHealthCheck   time.Time `json:"last_health_check"`
	ErrorCount        int64     `json:"error_count"`
	LastError         string    `json:"last_error"`
	LastErrorTime     time.Time `json:"last_error_time"`
}

MetricsSnapshot represents a point-in-time snapshot of metrics

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL