Skip to content

feat(worker): migrate worker and kafka metrics from statsd to prometheus - #64

Open
gmurayama wants to merge 1 commit into
masterfrom
feat/worker-metrics-prometheus
Open

feat(worker): migrate worker and kafka metrics from statsd to prometheus#64
gmurayama wants to merge 1 commit into
masterfrom
feat/worker-metrics-prometheus

Conversation

@gmurayama

Copy link
Copy Markdown
Collaborator

No description provided.

@vitorbaraujo
vitorbaraujo self-requested a review June 2, 2026 17:12

go func() {
for range producer.Successes() {
c.Statsd.Incr("send_message_return", []string{"error:false"}, 1)

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The new metric is called marathon_kafka_send_message_return_total, is the renaming expected? If that's the case, let's add a document under docs/ listing the changes in metrics and what consumers must do to adapt

Comment thread worker/metrics.go
// The metric name uses underscores; the DD OpenMetrics check maps marathon_* → marathon.*
workerCounter = prometheus.NewCounterVec(
prometheus.CounterOpts{
Name: "marathon_worker_events_total",

@vitorbaraujo vitorbaraujo Jun 2, 2026

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I didn't find where this metric was configured before. Just to confirm, is the metric name the same for this metric and the one below (marathon_worker_duration_milliseconds)?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants