Skip to content
This repository has been archived by the owner on Aug 23, 2023. It is now read-only.

Commit

Permalink
include the notifier type in metric names
Browse files Browse the repository at this point in the history
  • Loading branch information
woodsaj committed Nov 8, 2016
1 parent 71a0304 commit 6597795
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions mdata/notifierKafka/notifierKafka.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@ type NotifierKafka struct {
}

func NewNotifierKafka(instance string, metrics mdata.Metrics, stats met.Backend) *NotifierKafka {
messagesPublished = stats.NewCount("cluster.messages-published")
messagesSize = stats.NewMeter("cluster.message_size", 0)
messagesPublished = stats.NewCount("notifier.kafka.messages-published")
messagesSize = stats.NewMeter("notifier.kafka.message_size", 0)

client, err := sarama.NewClient(Brokers, Config)
if err != nil {
Expand Down
4 changes: 2 additions & 2 deletions mdata/notifierNsq/notifierNsq.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,8 +27,8 @@ type NotifierNSQ struct {
}

func NewNSQ(instance string, metrics mdata.Metrics, stats met.Backend) *NotifierNSQ {
messagesPublished = stats.NewCount("cluster.messages-published")
messagesSize = stats.NewMeter("cluster.message_size", 0)
messagesPublished = stats.NewCount("notifier.nsq.messages-published")
messagesSize = stats.NewMeter("notifier.nsq.message_size", 0)
// producers
hostPool = hostpool.NewEpsilonGreedy(NsqdAdds, 0, &hostpool.LinearEpsilonValueCalculator{})
producers = make(map[string]*nsq.Producer)
Expand Down

0 comments on commit 6597795

Please sign in to comment.