Function fetchServerGroupDetails

server_groups.go:242–291

fetchServerGroupDetails retrives the server group node hierarchy for all the given node UUIDs.

(mgr *cbgt.Manager, uuids []string)

// fetchServerGroupDetails retrives the server group node hierarchy
// for all the given node UUIDs.
func fetchServerGroupDetails(mgr *cbgt.Manager, uuids []string) (
	map[string]string, error) {
	if len(uuids) == 0 {
		return nil, fmt.Errorf("empty UUID list")
	}

	url := mgr.Server() + "/pools/default/serverGroups"
	u, err := cbgt.CBAuthURL(url)
	if err != nil {
		return nil, fmt.Errorf("server_groups: auth for ns_server,"+
			" url: %s, authType: %s, err: %v",
			url, "cbauth", err)
	}

	req, err := http.NewRequest("GET", u, nil)
	if err != nil {
		return nil, err
	}

	resp, err := cbgt.HttpClient().Do(req)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	respBuf, err := ioutil.ReadAll(resp.Body)
	if err != nil || len(respBuf) == 0 {
		return nil, fmt.Errorf("server_groups: error reading resp.Body,"+
			" url: %s, resp: %#v, err: %v", url, resp, err)
	}

	var sg serverGroups
	err = json.Unmarshal(respBuf, &sg)
	if err != nil {
		return nil, fmt.Errorf("server_groups: error parsing respBuf: %s,"+
			" url: %s, err: %v", respBuf, url, err)
	}

	uuidMap := cbgt.StringsToMap(uuids)
	nodeHierarchy := make(map[string]string, len(uuids))
	for _, g := range sg.ServerGroups {
		for _, nd := range g.NodeDetails {
			if _, found := uuidMap[nd.NodeUUID]; found {
				nodeHierarchy[nd.NodeUUID] = "datacenter/" + g.Name
			}
		}
	}

	return nodeHierarchy, nil
}

// listenStreamingEndpoint is a generic stream endpoint listen
// utility function which accepts callback methods for decoding the