From 53fa54d3d3bb73194656167ada1545312d0e0241 Mon Sep 17 00:00:00 2001 From: Travis Turner Date: Mon, 6 Nov 2017 09:17:50 -0600 Subject: [PATCH] 891 nodeid tags (from #897) --- server.go | 20 ++++++-------------- 1 file changed, 6 insertions(+), 14 deletions(-) diff --git a/server.go b/server.go index e460e1432..cfbf4ea73 100644 --- a/server.go +++ b/server.go @@ -130,21 +130,13 @@ func (s *Server) Open() error { // Set Cluster URI. s.Cluster.URI = s.URI - /* - // Create local node if no cluster is specified. - if len(s.Cluster.Nodes) == 0 { - s.Cluster.Nodes = []*Node{ - {Scheme: s.URI.Scheme(), Host: s.URI.HostPort()}, - } + // Find the Node ID and append that tag to stats. + for i, n := range s.Cluster.Nodes { + if n.URI == s.URI { + s.Holder.Stats = s.Holder.Stats.WithTags(fmt.Sprintf("NodeID:%d", i)) + break } - - // TODO: nodes aren't here yet. May need to merge new stats code anyway. - 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. s.Holder.LogOutput = s.LogOutput