telemetry

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 1, 2026

Changes in this version

type Log

+ func (l *Log) ContactDueFailed(count int)

+ func (l *Log) ContactDuePublished(count int)

+ func (l *Log) OutboundRateDeferred()

+ func (l *Log) SetThreadInvariantViolations(string, int)

+ func (l *Log) SetThreadNullMessages(string, int)

+ func (l *Log) SetThreadRelationshipPercent(string, float64)

+ func (l *Log) ThreadHeaderParseFailure(header string)

+ func (l *Log) ThreadResolution(source string, count int)

type Metrics

+ ContactDueFailed func(count int)

+ ContactDuePublished func(count int)

+ OutboundRateDeferred func()

+ SetThreadInvariantViolations func(kind string, count int)

+ SetThreadNullMessages func(ageBucket string, count int)

+ SetThreadRelationshipPercent func(kind string, percent float64)

+ ThreadHeaderParseFailure func(header string)

+ ThreadResolution func(source string, count int)

type NoOp

+ func (NoOp) ContactDueFailed(int)

+ func (NoOp) ContactDuePublished(int)

+ func (NoOp) OutboundRateDeferred()

+ func (NoOp) SetThreadInvariantViolations(string, int)

+ func (NoOp) SetThreadNullMessages(string, int)

+ func (NoOp) SetThreadRelationshipPercent(string, float64)

+ func (NoOp) ThreadHeaderParseFailure(string)

+ func (NoOp) ThreadResolution(string, int)

type Prom

+ func (p *Prom) ContactDueFailed(count int)

+ func (p *Prom) ContactDuePublished(count int)

+ func (p *Prom) OutboundRateDeferred()

+ func (p *Prom) SetThreadInvariantViolations(kind string, count int)

+ func (p *Prom) SetThreadNullMessages(ageBucket string, count int)

+ func (p *Prom) SetThreadRelationshipPercent(kind string, percent float64)

+ func (p *Prom) ThreadHeaderParseFailure(header string)

+ func (p *Prom) ThreadResolution(source string, count int)

v1.4.1

Jul 26, 2026

Changes in this version

+ func NormalizeBuildLabel(value string) string

type Log

+ func (l *Log) WebhookTerminal(outcome, scope string, count int)

type Metrics

+ WebhookTerminal func(outcome, scope string, count int)

type NoOp

+ func (NoOp) WebhookTerminal(string, string, int)

type Prom

+ func (p *Prom) WebhookTerminal(outcome, scope string, count int)

v1.4.0

Jul 26, 2026

v1.3.0

Jul 25, 2026

Changes in this version

type Log

+ func (l *Log) OutboundTerminalLatency(seconds float64)

+ func (l *Log) WSHandshakeRejected(reason string)

+ func (l *Log) WebhookDeliveryRescued(count int)

+ func (l *Log) WebhookExpiredPending(count int)

+ func (l *Log) WebhookFanOutRescued(count int)

+ func (l *Log) WebhookFirstAttemptLatency(seconds float64)

type Metrics

+ OutboundTerminalLatency func(seconds float64)

+ WSHandshakeRejected func(reason string)

+ WebhookDeliveryRescued func(count int)

+ WebhookExpiredPending func(count int)

+ WebhookFanOutRescued func(count int)

+ WebhookFirstAttemptLatency func(seconds float64)

type NoOp

+ func (NoOp) OutboundTerminalLatency(float64)

+ func (NoOp) WSHandshakeRejected(string)

+ func (NoOp) WebhookDeliveryRescued(int)

+ func (NoOp) WebhookExpiredPending(int)

+ func (NoOp) WebhookFanOutRescued(int)

+ func (NoOp) WebhookFirstAttemptLatency(float64)

type Prom

+ func (p *Prom) OutboundTerminalLatency(seconds float64)

+ func (p *Prom) WSHandshakeRejected(reason string)

+ func (p *Prom) WebhookDeliveryRescued(count int)

+ func (p *Prom) WebhookExpiredPending(count int)

+ func (p *Prom) WebhookFanOutRescued(count int)

+ func (p *Prom) WebhookFirstAttemptLatency(seconds float64)

v1.2.2

Jul 24, 2026

Changes in this version

type Log

+ func (l *Log) HTTPRequest(string, string, string, float64)

+ func (l *Log) InboundProcess(outcome string, seconds float64)

+ func (l *Log) OutboundAttempt(outcome string, seconds float64)

+ func (l *Log) OutboundQueueWait(float64)

+ func (l *Log) OutboundTerminal(outcome string)

+ func (l *Log) SMTPInbound(outcome string, seconds float64)

+ func (l *Log) SetQueueDepth(queue, state string, n int)

+ func (l *Log) SetQueueOldestAge(queue string, seconds float64)

+ func (l *Log) SetWSActive(int)

+ func (l *Log) WSConnected()

+ func (l *Log) WSDisconnected(reason string)

+ func (l *Log) WSDrained(count int)

+ func (l *Log) WSSendFailure()

+ func (l *Log) WebhookAttempt(outcome, statusClass string, seconds float64)

type Metrics

+ HTTPRequest func(method, route, statusClass string, seconds float64)

+ InboundProcess func(outcome string, seconds float64)

+ OutboundAttempt func(outcome string, seconds float64)

+ OutboundQueueWait func(seconds float64)

+ OutboundTerminal func(outcome string)

+ SMTPInbound func(outcome string, seconds float64)

+ SetQueueDepth func(queue, state string, n int)

+ SetQueueOldestAge func(queue string, seconds float64)

+ SetWSActive func(n int)

+ WSConnected func()

+ WSDisconnected func(reason string)

+ WSDrained func(count int)

+ WSSendFailure func()

+ WebhookAttempt func(outcome, statusClass string, seconds float64)

type NoOp

+ func (NoOp) HTTPRequest(string, string, string, float64)

+ func (NoOp) InboundProcess(string, float64)

+ func (NoOp) OutboundAttempt(string, float64)

+ func (NoOp) OutboundQueueWait(float64)

+ func (NoOp) OutboundTerminal(string)

+ func (NoOp) SMTPInbound(string, float64)

+ func (NoOp) SetQueueDepth(string, string, int)

+ func (NoOp) SetQueueOldestAge(string, float64)

+ func (NoOp) SetWSActive(int)

+ func (NoOp) WSConnected()

+ func (NoOp) WSDisconnected(string)

+ func (NoOp) WSDrained(int)

+ func (NoOp) WSSendFailure()

+ func (NoOp) WebhookAttempt(string, string, float64)

+ type Prom struct

+ func NewProm() *Prom

+ func (p *Prom) HTTPRequest(method, route, statusClass string, seconds float64)

+ func (p *Prom) Handler() http.Handler

+ func (p *Prom) InboundProcess(outcome string, seconds float64)

+ func (p *Prom) JanitorRowsDeleted(table string, count int)

+ func (p *Prom) NotifyMissed()

+ func (p *Prom) OutboundAttempt(outcome string, seconds float64)

+ func (p *Prom) OutboundQueueWait(seconds float64)

+ func (p *Prom) OutboundTerminal(outcome string)

+ func (p *Prom) OutboxEventsFanOut(eventType string, matched int)

+ func (p *Prom) OutboxEventsNoMatch(eventType string)

+ func (p *Prom) OutboxEventsPublished(eventType string)

+ func (p *Prom) OutboxFailures(stage string)

+ func (p *Prom) RedeliverRequests(scope string)

+ func (p *Prom) SMTPInbound(outcome string, seconds float64)

+ func (p *Prom) SetPublisherLag(sec float64)

+ func (p *Prom) SetQueueDepth(queue, state string, n int)

+ func (p *Prom) SetQueueOldestAge(queue string, seconds float64)

+ func (p *Prom) SetWSActive(n int)

+ func (p *Prom) WSConnected()

+ func (p *Prom) WSDisconnected(reason string)

+ func (p *Prom) WSDrained(count int)

+ func (p *Prom) WSSendFailure()

+ func (p *Prom) WebhookAttempt(outcome, statusClass string, seconds float64)

v1.2.1

Jul 23, 2026

v1.2.0

Jul 22, 2026

v1.1.0

Jul 21, 2026

Changes in this version

+ type Log struct

+ func NewLog() *Log

+ func (l *Log) JanitorRowsDeleted(table string, count int)

+ func (l *Log) NotifyMissed()

+ func (l *Log) OutboxEventsFanOut(eventType string, matched int)

+ func (l *Log) OutboxEventsNoMatch(eventType string)

+ func (l *Log) OutboxEventsPublished(eventType string)

+ func (l *Log) OutboxFailures(stage string)

+ func (l *Log) RedeliverRequests(scope string)

+ func (l *Log) SetPublisherLag(seconds float64)

+ type Metrics interface

+ JanitorRowsDeleted func(table string, count int)

+ NotifyMissed func()

+ OutboxEventsFanOut func(eventType string, matched int)

+ OutboxEventsNoMatch func(eventType string)

+ OutboxEventsPublished func(eventType string)

+ OutboxFailures func(stage string)

+ RedeliverRequests func(scope string)

+ SetPublisherLag func(seconds float64)

+ type NoOp struct

+ func (NoOp) JanitorRowsDeleted(string, int)

+ func (NoOp) NotifyMissed()

+ func (NoOp) OutboxEventsFanOut(string, int)

+ func (NoOp) OutboxEventsNoMatch(string)

+ func (NoOp) OutboxEventsPublished(string)

+ func (NoOp) OutboxFailures(string)

+ func (NoOp) RedeliverRequests(string)

+ func (NoOp) SetPublisherLag(float64)

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