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
}