(raw []byte)
| 379 | } |
| 380 | |
| 381 | func parseClusterNodesPayload(raw []byte) ([]clusterNode, error) { |
| 382 | var envelope clusterNodesEnvelope |
| 383 | if errUnmarshal := json.Unmarshal(raw, &envelope); errUnmarshal != nil { |
| 384 | return nil, errUnmarshal |
| 385 | } |
| 386 | return normalizeClusterNodes(envelope.Nodes), nil |
| 387 | } |
| 388 | |
| 389 | func (c *Client) updateClusterNodesFromPayload(raw []byte) error { |
| 390 | if c == nil || !c.clusterDiscoveryEnabled() { |
no test coverage detected