func checkLDS()

in dp_check/dp_check.go [984:995]


func checkLDS(stream adsStream, node *v3corepb.Node, versionInfoMap, nonceMap map[string]string) (string, error) {
	ldsReply, err := sendXdsRequest(stream, node, V3ListenerURL, *service, versionInfoMap, nonceMap)
	if err != nil {
		return "", fmt.Errorf("fail to send LDS request: %v", err)
	}
	clusterName, err := processLdsResponse(ldsReply)
	if err != nil {
		return "", fmt.Errorf("fail to process LDS response: %v", err)
	}
	infoLog.Printf("Successfully extract cluster_name from LDS response: |%+v|", clusterName)
	return clusterName, nil
}