Documentation
¶
Overview ¶
Package metrics owns AgentSQL's private Prometheus registry and observers.
Index ¶
- type Metrics
- func (metrics *Metrics) Handler() http.Handler
- func (metrics *Metrics) IncRedactionKeyDrift(kind string)
- func (metrics *Metrics) IncRejected(reason string)
- func (metrics *Metrics) ObserveB2Phase(phase string, duration time.Duration)
- func (metrics *Metrics) ObserveDecision(decision, dialect, stmtType string)
- func (metrics *Metrics) ObserveHTTP(method, route, status string, seconds float64)
- func (metrics *Metrics) ObserveRuleHit(ruleID, decision, risk string)
- func (metrics *Metrics) ObserveStage(stage string, latencyMS int64)
- func (metrics *Metrics) RecordNotificationDropped(channel string)
- func (metrics *Metrics) RecordNotificationFailed(channel, reason string)
- func (metrics *Metrics) RecordNotificationSent(channel string, at time.Time)
- func (metrics *Metrics) SetAuditChainLastVerified(domain string, at time.Time)
- func (metrics *Metrics) SetAuditChainValid(domain string, valid bool)
- func (metrics *Metrics) SetAuditChainVerificationLag(domain string, lagging bool)
- func (metrics *Metrics) SetAuditWriterReady(domain string, ready bool)
- func (metrics *Metrics) SetB2State(state string)
- func (metrics *Metrics) SetOutboxPending(count int, oldestAge time.Duration)
- type PoolStat
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Metrics ¶
type Metrics struct {
// contains filtered or unexported fields
}
Metrics owns the process-local AgentSQL Prometheus registry.
func (*Metrics) IncRedactionKeyDrift ¶
IncRedactionKeyDrift records one bounded reconciliation finding. kind must be supplied by the reconciliation classifier, never from an external error.
func (*Metrics) IncRejected ¶
IncRejected increments one bounded gateway rejection reason.
func (*Metrics) ObserveB2Phase ¶
ObserveB2Phase records a phase duration. Phase names are internal constants, never attacker-provided labels.
func (*Metrics) ObserveDecision ¶
ObserveDecision records one final pipeline decision.
func (*Metrics) ObserveHTTP ¶
ObserveHTTP records one normalized HTTP request and its duration.
func (*Metrics) ObserveRuleHit ¶
ObserveRuleHit records one rule hit from a final assessment.
func (*Metrics) ObserveStage ¶
ObserveStage records one final pipeline stage latency after converting ms to seconds.
func (*Metrics) RecordNotificationDropped ¶
RecordNotificationDropped records one queue-full best-effort drop.
func (*Metrics) RecordNotificationFailed ¶
RecordNotificationFailed records a terminal delivery failure. reason is a bounded category supplied by notify and never contains a URL or payload.
func (*Metrics) RecordNotificationSent ¶
RecordNotificationSent records a completed delivery and clears last_error.
func (*Metrics) SetAuditChainLastVerified ¶
SetAuditChainLastVerified records the completion time of the latest verification.
func (*Metrics) SetAuditChainValid ¶
SetAuditChainValid updates whether the latest verification reached a valid observed head.
func (*Metrics) SetAuditChainVerificationLag ¶
SetAuditChainVerificationLag updates the domain-scoped verification lag alarm.
func (*Metrics) SetAuditWriterReady ¶
SetAuditWriterReady updates the domain-scoped audit writer key readiness.
func (*Metrics) SetB2State ¶
SetB2State updates the one-hot activation/readiness state.
Source Files