buildPeerNode takes a serf member and returns a peerNode
(m serf.Member)
| 283 | |
| 284 | // buildPeerNode takes a serf member and returns a peerNode |
| 285 | func buildPeerNode(m serf.Member) (*peerNode, error) { |
| 286 | name := m.Name |
| 287 | portString, ok := m.Tags[externalRpcTag] |
| 288 | if !ok { |
| 289 | return nil, fmt.Errorf("member joined without the rpc port set: %+v", m) |
| 290 | } |
| 291 | |
| 292 | port, err := strconv.ParseInt(portString, 0, 0) |
| 293 | if err != nil { |
| 294 | return nil, fmt.Errorf("couldn't parse rpc port string %v for member %+v", portString, m) |
| 295 | } |
| 296 | |
| 297 | return &peerNode{ |
| 298 | name: name, |
| 299 | addr: m.Addr.String(), |
| 300 | port: int(port), |
| 301 | }, nil |
| 302 | } |
| 303 | |
| 304 | // garbageCollect scans for stored keys that this node doesn't own or should not |
| 305 | // be replicated to it and removes them. |
no outgoing calls