func checkEDS()

in dp_check/dp_check.go [1039:1052]

• 14 lines of code
• 4 McCabe index (conditional complexity)

func checkEDS(stream adsStream, node *v3corepb.Node, serviceName string, versionInfoMap, nonceMap map[string]string) ([]string, error) {
	edsReply, err := sendXdsRequest(stream, node, V3EndpointsURL, serviceName, versionInfoMap, nonceMap)
	if err != nil {
		return []string{}, fmt.Errorf("fail to send EDS request: %v", err)
	}
	xdsBackendAddrs, err := processEdsResponse(edsReply)
	if err != nil {
		return []string{}, fmt.Errorf("fail to process EDS response: %v", err)
	}
	if len(xdsBackendAddrs) == 0 {
		return []string{}, fmt.Errorf("no backend addresses received in EDS response: %v", err)
	}
	return xdsBackendAddrs, nil
}