metrics

package

v0.52.0 Latest Latest Go to latest Published: Jun 25, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

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

Repository

github.com/rabbitmq/omq

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func MessagesConsumedGapsMetric(priority int) *vmetrics.Counter
func MessagesConsumedMetric(priority int) *vmetrics.Counter
func MessagesConsumedOutOfOrderMetric(priority int) *vmetrics.Counter
func RecordDelayAccuracy(accuracy time.Duration)
func RecordEndToEndLatency(latency time.Duration)
func RecordPublishingLatency(latency time.Duration)
type MetricsServer
- func Start(ctx context.Context, cfg config.Config) *MetricsServer

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	CommandLineArgs   *vmetrics.Gauge
	MessagesPublished *vmetrics.Counter
	MessagesConfirmed *vmetrics.Counter
	MessagesReturned  *vmetrics.Counter

	MessagesDeliveredTooEarly *vmetrics.Counter
	PublishingLatency         *vmetrics.Summary
	EndToEndLatency           *vmetrics.Summary
	DelayAccuracy             *vmetrics.Summary
)

Functions ¶

func MessagesConsumedGapsMetric ¶ added in v0.44.0

func MessagesConsumedGapsMetric(priority int) *vmetrics.Counter

func MessagesConsumedMetric ¶ added in v0.8.0

func MessagesConsumedMetric(priority int) *vmetrics.Counter

func MessagesConsumedOutOfOrderMetric ¶ added in v0.8.0

func MessagesConsumedOutOfOrderMetric(priority int) *vmetrics.Counter

func RecordDelayAccuracy ¶ added in v0.47.0

func RecordDelayAccuracy(accuracy time.Duration)

func RecordEndToEndLatency ¶ added in v0.40.0

func RecordEndToEndLatency(latency time.Duration)

func RecordPublishingLatency ¶ added in v0.40.0

func RecordPublishingLatency(latency time.Duration)

Types ¶

type MetricsServer ¶

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

func Start ¶ added in v0.23.0

func Start(ctx context.Context, cfg config.Config) *MetricsServer

func (MetricsServer) PrintAll ¶ added in v0.17.0

func (m MetricsServer) PrintAll()

func (*MetricsServer) PrintSummary ¶ added in v0.17.0

func (m *MetricsServer) PrintSummary()

func (*MetricsServer) StartTime ¶ added in v0.26.0

func (m *MetricsServer) StartTime(t time.Time)

func (*MetricsServer) Stop ¶

func (m *MetricsServer) Stop()

Source Files ¶

View all Source files

metrics.go

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