metrics

package

v0.35.1 Latest Latest Go to latest Published: Feb 13, 2026 License: Apache-2.0 Imports: 18 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 MessagesConsumedMetric(priority int) *vmetrics.Counter
func MessagesConsumedOutOfOrderMetric(priority int) *vmetrics.Counter
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 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

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