metrics

package

v0.2.0 Latest Latest Go to latest Published: Feb 20, 2026 License: MIT Imports: 5 Imported by: 0

Details

包 metrics 提供内部指标采集与上报能力。

该包包含 AgentFlow 在 `internal/metrics` 目录下的核心实现。

This section is empty.

This section is empty.

This section is empty.

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

Collector 指标收集器

func NewCollector(namespace string, logger *zap.Logger) *Collector

NewCollector 创建指标收集器

func (c *Collector) RecordAgentExecution(agentID, agentType, status string, duration time.Duration)

RecordAgentExecution 记录 Agent 执行

func (c *Collector) RecordAgentStateTransition(agentID, fromState, toState string)

RecordAgentStateTransition 记录 Agent 状态转换

func (c *Collector) RecordCacheHit(cacheType string)

RecordCacheHit 记录缓存命中

func (c *Collector) RecordCacheMiss(cacheType string)

RecordCacheMiss 记录缓存未命中

func (c *Collector) RecordDBConnections(database string, open, idle int)

RecordDBConnections 记录数据库连接数

func (c *Collector) RecordDBQuery(database, operation string, duration time.Duration)

RecordDBQuery 记录数据库查询

func (c *Collector) RecordHTTPRequest(method, path string, status int, duration time.Duration, requestSize, responseSize int64)

RecordHTTPRequest 记录 HTTP 请求

func (c *Collector) RecordLLMRequest(provider, model, status string, duration time.Duration, promptTokens, completionTokens int, cost float64)

RecordLLMRequest 记录 LLM 请求