Method getSupervisorMaps

query_supervisor.go:243–344

(nodeDefs *cbgt.NodeDefs,
	indexName string, longerThan string)

}

func (qss *QuerySupervisorDetails) getSupervisorMaps(nodeDefs *cbgt.NodeDefs,
	indexName string, longerThan string) ([]response, map[string]string) {
	type supervisorReq struct {
		uuid string
		url  string
	}
	type supervisorResp struct {
		uuid string
		data responseData
		err  error
	}

	supervisorDetailsURLs, urlErrs := qss.getURLs(nodeDefs, indexName,
		longerThan)
	var wg sync.WaitGroup
	groupSize := getWorkerCount(len(supervisorDetailsURLs))
	requestCh := make(chan *supervisorReq, len(supervisorDetailsURLs))
	responseCh := make(chan *supervisorResp, len(supervisorDetailsURLs))

	for i := 0; i < groupSize; i++ {
		wg.Add(1)
		go func() {
			for reqs := range requestCh {
				ctx, ctxCancel := context.WithTimeout(context.Background(),
					60*time.Second)
				req, err := http.NewRequestWithContext(ctx, "GET", reqs.url, nil)
				req.Header.Add(rest.CLUSTER_ACTION, clusterActionScatterGather)
				if err != nil {
					ctxCancel()
					responseCh <- &supervisorResp{
						uuid: reqs.uuid,
						err: fmt.Errorf("failed to form a request"+
							" to node: %s, err: %v", reqs.uuid, err),
					}
					continue
				}

				httpClient := cbgt.HttpClient()
				res, err := httpClient.Do(req)
				ctxCancel()
				if err != nil {
					responseCh <- &supervisorResp{
						uuid: reqs.uuid,
						err: fmt.Errorf("failed to send a request to node:"+
							" %s, err: %v", reqs.uuid, err),
					}
					continue
				}
				data, derr := ioutil.ReadAll(res.Body)
				res.Body.Close()
				if derr != nil {
					responseCh <- &supervisorResp{
						uuid: reqs.uuid,
						err: fmt.Errorf("error in decoding response from node:"+
							" %s, err: %v", reqs.uuid, derr),
					}
					continue
				}