(addr string)
| 153 | } |
| 154 | |
| 155 | func (s *Server) member(addr string) *pb.Member { |
| 156 | s.AssertRLock() |
| 157 | for _, m := range s.state.Zeros { |
| 158 | if m.Addr == addr { |
| 159 | return m |
| 160 | } |
| 161 | } |
| 162 | for _, g := range s.state.Groups { |
| 163 | for _, m := range g.Members { |
| 164 | if m.Addr == addr { |
| 165 | return m |
| 166 | } |
| 167 | } |
| 168 | } |
| 169 | return nil |
| 170 | } |
| 171 | |
| 172 | // Leader returns a connection pool to the zero leader. |
| 173 | func (s *Server) Leader(gid uint32) *conn.Pool { |
no test coverage detected