observability

package

v0.3.0 Latest Latest Go to latest Published: Jun 8, 2025 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dysodeng/mq

Links

Open Source Insights

Documentation ¶

Index ¶

type MetricsRecorder
- func NewMetricsRecorder(observer Observer, adapter string) (*MetricsRecorder, error)
type Observer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type MetricsRecorder ¶

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

MetricsRecorder 指标记录器

func NewMetricsRecorder ¶

func NewMetricsRecorder(observer Observer, adapter string) (*MetricsRecorder, error)

NewMetricsRecorder 创建指标记录器

func (*MetricsRecorder) LogDebug ¶

func (m *MetricsRecorder) LogDebug(msg string, fields ...zap.Field)

LogDebug 记录调试日志

func (*MetricsRecorder) LogError ¶

func (m *MetricsRecorder) LogError(msg string, err error, fields ...zap.Field)

LogError 记录错误日志

func (*MetricsRecorder) LogInfo ¶

func (m *MetricsRecorder) LogInfo(msg string, fields ...zap.Field)

LogInfo 记录信息日志

func (*MetricsRecorder) LogWarn ¶

func (m *MetricsRecorder) LogWarn(msg string, fields ...zap.Field)

LogWarn 记录警告日志

func (*MetricsRecorder) RecordConnectionPoolSize ¶

func (m *MetricsRecorder) RecordConnectionPoolSize(ctx context.Context, size int64)

RecordConnectionPoolSize 记录连接池大小

func (*MetricsRecorder) RecordErrorRate ¶

func (m *MetricsRecorder) RecordErrorRate(ctx context.Context, topic string, rate float64)

RecordErrorRate 记录错误率

func (*MetricsRecorder) RecordMessageFailed ¶

func (m *MetricsRecorder) RecordMessageFailed(ctx context.Context, topic string, err error)

RecordMessageFailed 记录消息失败

func (*MetricsRecorder) RecordMessageLatency ¶

func (m *MetricsRecorder) RecordMessageLatency(ctx context.Context, topic string, latency time.Duration)

RecordMessageLatency 记录消息延迟

func (*MetricsRecorder) RecordMessageReceived ¶

func (m *MetricsRecorder) RecordMessageReceived(ctx context.Context, topic string)

RecordMessageReceived 记录消息接收

func (*MetricsRecorder) RecordMessageSent ¶

func (m *MetricsRecorder) RecordMessageSent(ctx context.Context, topic string)

RecordMessageSent 记录消息发送

func (*MetricsRecorder) RecordProcessingError ¶

func (m *MetricsRecorder) RecordProcessingError(ctx context.Context, topic string, errorType string)

RecordProcessingError 记录处理错误

func (*MetricsRecorder) RecordProcessingTime ¶

func (m *MetricsRecorder) RecordProcessingTime(ctx context.Context, topic string, duration time.Duration)

RecordProcessingTime 记录处理时间

func (*MetricsRecorder) RecordQueueBacklog ¶

func (m *MetricsRecorder) RecordQueueBacklog(ctx context.Context, topic string, backlog int64)

RecordQueueBacklog 记录队列积压

func (*MetricsRecorder) RecordQueueSize ¶

func (m *MetricsRecorder) RecordQueueSize(ctx context.Context, topic string, size int64)

RecordQueueSize 记录队列大小

func (*MetricsRecorder) RecordRetryAttempt ¶

func (m *MetricsRecorder) RecordRetryAttempt(ctx context.Context, topic string, attempt int)

RecordRetryAttempt 记录重试尝试

func (*MetricsRecorder) RecordThroughput ¶

func (m *MetricsRecorder) RecordThroughput(ctx context.Context, topic string, count float64)

RecordThroughput 记录吞吐量

type Observer ¶

type Observer interface {
	// GetMeter 获取OpenTelemetry Meter实例
	GetMeter() metric.Meter
	// GetLogger 获取zap Logger实例
	GetLogger() *zap.Logger
}

Observer 可观测性接口，由外部调用方实现并注入

Source Files ¶

View all Source files

observability.go

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