Documentation
¶
Overview ¶
Package metrics provides comprehensive metrics for TokMan.
Index ¶
- func RecordCommandProcessedWithContext(ctx context.Context)
- func RecordCompressionWithContext(ctx context.Context, duration time.Duration, inputTokens, outputTokens int64)
- func RecordErrorWithContext(ctx context.Context)
- type Metrics
- func (m *Metrics) DecActiveConnections()
- func (m *Metrics) IncActiveConnections()
- func (m *Metrics) RecordCacheHit()
- func (m *Metrics) RecordCacheMiss()
- func (m *Metrics) RecordCommandFailed()
- func (m *Metrics) RecordCommandProcessed()
- func (m *Metrics) RecordCompressionDuration(d time.Duration)
- func (m *Metrics) RecordCompressionError()
- func (m *Metrics) RecordCompressionRun()
- func (m *Metrics) Reset()
- func (m *Metrics) SetMemoryUsage(mb int64)
- func (m *Metrics) SetQueueSize(size int64)
- func (m *Metrics) Snapshot() Snapshot
- type Snapshot
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RecordCommandProcessedWithContext ¶ added in v0.28.0
RecordCommandProcessedWithContext records a processed command (context retained for API compatibility).
func RecordCompressionWithContext ¶ added in v0.28.0
func RecordCompressionWithContext(ctx context.Context, duration time.Duration, inputTokens, outputTokens int64)
RecordCompressionWithContext records compression with context (context retained for API compatibility).
func RecordErrorWithContext ¶ added in v0.28.0
RecordErrorWithContext records an error with context (context retained for API compatibility).
Types ¶
type Metrics ¶ added in v0.28.0
type Metrics struct {
// contains filtered or unexported fields
}
Metrics holds all metrics for TokMan
func GetMetrics ¶ added in v0.28.0
GetMetrics returns the global metrics instance (context parameter retained for API compatibility).
func (*Metrics) DecActiveConnections ¶ added in v0.28.0
func (m *Metrics) DecActiveConnections()
DecActiveConnections decrements active connections
func (*Metrics) IncActiveConnections ¶ added in v0.28.0
func (m *Metrics) IncActiveConnections()
IncActiveConnections increments active connections
func (*Metrics) RecordCacheHit ¶ added in v0.28.0
func (m *Metrics) RecordCacheHit()
RecordCacheHit records a cache hit
func (*Metrics) RecordCacheMiss ¶ added in v0.28.0
func (m *Metrics) RecordCacheMiss()
RecordCacheMiss records a cache miss
func (*Metrics) RecordCommandFailed ¶ added in v0.28.0
func (m *Metrics) RecordCommandFailed()
RecordCommandFailed records a failed command
func (*Metrics) RecordCommandProcessed ¶ added in v0.28.0
func (m *Metrics) RecordCommandProcessed()
RecordCommandProcessed records a processed command
func (*Metrics) RecordCompressionDuration ¶ added in v0.28.0
RecordCompressionDuration records compression duration using atomic operations
func (*Metrics) RecordCompressionError ¶ added in v0.28.0
func (m *Metrics) RecordCompressionError()
RecordCompressionError records a compression error
func (*Metrics) RecordCompressionRun ¶ added in v0.28.0
func (m *Metrics) RecordCompressionRun()
RecordCompressionRun records a compression run
func (*Metrics) SetMemoryUsage ¶ added in v0.28.0
SetMemoryUsage sets memory usage in MB
func (*Metrics) SetQueueSize ¶ added in v0.28.0
SetQueueSize sets the current queue size
type Snapshot ¶ added in v0.28.0
type Snapshot struct {
CommandsProcessed int64 `json:"commands_processed"`
CommandsFailed int64 `json:"commands_failed"`
CompressionRuns int64 `json:"compression_runs"`
CompressionErrors int64 `json:"compression_errors"`
CacheHits int64 `json:"cache_hits"`
CacheMisses int64 `json:"cache_misses"`
ActiveConnections int64 `json:"active_connections"`
MemoryUsageMB int64 `json:"memory_usage_mb"`
QueueSize int64 `json:"queue_size"`
UptimeSeconds float64 `json:"uptime_seconds"`
CompressionRate float64 `json:"compression_rate"`
CacheHitRate float64 `json:"cache_hit_rate"`
AverageDurationMs float64 `json:"average_duration_ms"`
}
Snapshot represents a point-in-time metrics snapshot
Source Files