Function getStatsUrls

pindex_copy_request.go:331–367

getStatsUrls forms the stats url map.

(uuids []string, authType string,
	nodeDefs *cbgt.NodeDefs)

// getStatsUrls forms the stats url map.
func getStatsUrls(uuids []string, authType string,
	nodeDefs *cbgt.NodeDefs) map[string]string {
	nodeURL := make(map[string]string)
	if nodeDefs == nil {
		return nodeURL
	}

	urlWithAuth := func(authType, urlStr string) (string, error) {
		if authType == "cbauth" {
			return cbgt.CBAuthURL(urlStr)
		}
		return urlStr, nil
	}

	ss := cbgt.GetSecuritySetting()

	for _, uuid := range uuids {
		if node, ok := nodeDefs.NodeDefs[uuid]; ok {
			hostPortUrl := "http://" + node.HostPort
			if ss.EncryptionEnabled {
				if u, err := node.HttpsURL(); err == nil {
					hostPortUrl = u
				}
			}

			urlStr := hostPortUrl + "/api/stats?partitions=true"
			urlStr, err := urlWithAuth(authType, urlStr)
			if err != nil {
				continue
			}

			nodeURL[uuid] = urlStr
		}
	}

	return nodeURL
}

// srcPartition wraps the potential source partition
// with additional info to help prioritising it.