metrics

package

v0.2.1 Latest Latest Go to latest Published: Apr 27, 2026 License: AGPL-3.0 Imports: 3 Imported by: 0

Details

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

Repository

github.com/n0rdy/forq

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type NoopMetricsService
type PrometheusMetricsService
type Service
- func NewMetricsService(metricsEnabled bool) Service

Constants ¶

View Source

const (
	FailedMovedToDlqReason  = "failed"
	ExpiredMovedToDlqReason = "expired"

	FailedCleanupReason        = "failed"
	ExpiredCleanupReason       = "expired"
	DeletedByUserCleanupReason = "deleted_by_user"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type NoopMetricsService ¶

type NoopMetricsService struct {
}

func (*NoopMetricsService) IncMessagesAckedTotalBy ¶

func (nms *NoopMetricsService) IncMessagesAckedTotalBy(count int64, queueName string)

func (*NoopMetricsService) IncMessagesCleanupTotalBy ¶

func (nms *NoopMetricsService) IncMessagesCleanupTotalBy(count int64, reason string)

func (*NoopMetricsService) IncMessagesConsumedTotalBy ¶

func (nms *NoopMetricsService) IncMessagesConsumedTotalBy(count int64, queueName string)

func (*NoopMetricsService) IncMessagesMovedToDlqTotalBy ¶

func (nms *NoopMetricsService) IncMessagesMovedToDlqTotalBy(count int64, reason string)

func (*NoopMetricsService) IncMessagesNackedTotalBy ¶

func (nms *NoopMetricsService) IncMessagesNackedTotalBy(count int64, queueName string)

func (*NoopMetricsService) IncMessagesProducedTotalBy ¶

func (nms *NoopMetricsService) IncMessagesProducedTotalBy(count int64, queueName string)

func (*NoopMetricsService) IncMessagesRequeuedTotalBy ¶

func (nms *NoopMetricsService) IncMessagesRequeuedTotalBy(count int64, queueName string)

func (*NoopMetricsService) IncMessagesStaleRecoveredTotalBy ¶

func (nms *NoopMetricsService) IncMessagesStaleRecoveredTotalBy(count int64)

func (*NoopMetricsService) SetQueueDepth ¶

func (nms *NoopMetricsService) SetQueueDepth(queueName string, depth int64)

type PrometheusMetricsService ¶

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

func (*PrometheusMetricsService) IncMessagesAckedTotalBy ¶

func (pms *PrometheusMetricsService) IncMessagesAckedTotalBy(count int64, queueName string)

func (*PrometheusMetricsService) IncMessagesCleanupTotalBy ¶

func (pms *PrometheusMetricsService) IncMessagesCleanupTotalBy(count int64, reason string)

func (*PrometheusMetricsService) IncMessagesConsumedTotalBy ¶

func (pms *PrometheusMetricsService) IncMessagesConsumedTotalBy(count int64, queueName string)

func (*PrometheusMetricsService) IncMessagesMovedToDlqTotalBy ¶

func (pms *PrometheusMetricsService) IncMessagesMovedToDlqTotalBy(count int64, reason string)

func (*PrometheusMetricsService) IncMessagesNackedTotalBy ¶

func (pms *PrometheusMetricsService) IncMessagesNackedTotalBy(count int64, queueName string)

func (*PrometheusMetricsService) IncMessagesProducedTotalBy ¶

func (pms *PrometheusMetricsService) IncMessagesProducedTotalBy(count int64, queueName string)

func (*PrometheusMetricsService) IncMessagesRequeuedTotalBy ¶

func (pms *PrometheusMetricsService) IncMessagesRequeuedTotalBy(count int64, queueName string)

func (*PrometheusMetricsService) IncMessagesStaleRecoveredTotalBy ¶

func (pms *PrometheusMetricsService) IncMessagesStaleRecoveredTotalBy(count int64)

func (*PrometheusMetricsService) SetQueueDepth ¶

func (pms *PrometheusMetricsService) SetQueueDepth(queueName string, depth int64)

type Service ¶

type Service interface {
	IncMessagesProducedTotalBy(count int64, queueName string)
	IncMessagesConsumedTotalBy(count int64, queueName string)
	IncMessagesAckedTotalBy(count int64, queueName string)
	IncMessagesNackedTotalBy(count int64, queueName string)
	IncMessagesRequeuedTotalBy(count int64, queueName string)
	SetQueueDepth(queueName string, depth int64)
	IncMessagesMovedToDlqTotalBy(count int64, reason string)
	IncMessagesStaleRecoveredTotalBy(count int64)
	IncMessagesCleanupTotalBy(count int64, reason string)
}

func NewMetricsService ¶

func NewMetricsService(metricsEnabled bool) Service

Source Files ¶

View all Source files

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