From 878b188155e7fde5a7a4fe27780bb52eef118f60 Mon Sep 17 00:00:00 2001 From: Travis Turner Date: Wed, 24 Jan 2018 17:03:58 -0600 Subject: [PATCH] add accessor method for Node.status --- cluster.go | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/cluster.go b/cluster.go index 83b26b321..d51e1f88f 100644 --- a/cluster.go +++ b/cluster.go @@ -42,10 +42,17 @@ type Node struct { Scheme string `json:"scheme"` Host string `json:"host"` - mu sync.Mutex + mu sync.RWMutex status *internal.NodeStatus `json:"status"` } +// Status gets the NodeStatus. +func (n *Node) Status() *internal.NodeStatus { + n.mu.RLock() + defer n.mu.RUnlock() + return n.status +} + // SetStatus sets the NodeStatus. func (n *Node) SetStatus(s *internal.NodeStatus) { n.mu.Lock() @@ -203,7 +210,7 @@ func (c *Cluster) Status() *internal.ClusterStatus { func encodeClusterStatus(a []*Node) []*internal.NodeStatus { other := make([]*internal.NodeStatus, len(a)) for i := range a { - other[i] = a[i].status + other[i] = a[i].Status() } return other }