From 4328cc88cc17b3e0399b5f56660baece1a83ea4c Mon Sep 17 00:00:00 2001 From: Linh Vo Date: Wed, 17 May 2017 16:23:34 -0500 Subject: [PATCH] add nodeID tag --- server.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/server.go b/server.go index 2c86ad4ae..d1030c021 100644 --- a/server.go +++ b/server.go @@ -120,6 +120,12 @@ func (s *Server) Open() error { s.Cluster.Nodes = []*Node{{Host: s.Host}} } + for i, n := range s.Cluster.Nodes { + if s.Cluster.NodeByHost(n.Host) != nil { + s.Holder.Stats = s.Holder.Stats.WithTags(fmt.Sprintf("NodeID:%d", i)) + } + } + // Open holder. if err := s.Holder.Open(); err != nil { return err