Java源码示例:io.github.jhipster.registry.web.rest.vm.RouteVM

示例1
@GetMapping("/routes")
@Timed
public ResponseEntity<List<RouteVM>> getRoutes() {

    List<Route> routes = routeLocator.getRoutes();
    Map<String, RouteVM> routeVMs = new HashMap<>();
    routeVMs.put(null, registryRoute());

    routes.forEach(route -> {
        RouteVM routeVM = new RouteVM();
        routeVM.setPath(route.getFullPath());
        routeVM.setPrefix(route.getPrefix());
        routeVM.setAppName(extractName(route.getId()));
        routeVM.setServiceId(route.getId());
        routeVM.setServiceInstances(discoveryClient.getInstances(route.getId()));
        routeVMs.put(route.getId(), routeVM);
    });

    fillStatus(routeVMs);

    return new ResponseEntity<>(new ArrayList<>(routeVMs.values()), HttpStatus.OK);
}
 
示例2
@GetMapping("/routes")
public ResponseEntity<List<RouteVM>> getRoutes() {

    List<Route> routes = routeLocator.getRoutes();
    Map<String, RouteVM> routeVMs = new HashMap<>();
    routeVMs.put(null, registryRoute());

    routes.stream()
        .map(route -> {
            RouteVM routeVM = new RouteVM();
            routeVM.setPath(route.getFullPath());
            routeVM.setPrefix(route.getPrefix());
            routeVM.setAppName(extractName(route.getId()));
            routeVM.setServiceId(route.getId());
            routeVM.setServiceInstances(discoveryClient.getInstances(route.getId()));

            return routeVM;
        })
        // we don't need the service sets. They come in as of eureka.fetch-registry=true, which is needed for requests against UAA
        .filter(routeVM -> routeVM.getServiceInstances() == null || routeVM.getServiceInstances().isEmpty())
        .forEach(route -> routeVMs.put(route.getServiceId(), route));

    fillStatus(routeVMs);

    return new ResponseEntity<>(new ArrayList<>(routeVMs.values()), HttpStatus.OK);
}
 
示例3
@GetMapping("/routes")
@Timed
public ResponseEntity<List<RouteVM>> getRoutes() {

    List<Route> routes = routeLocator.getRoutes();
    Map<String, RouteVM> routeVMs = new HashMap<>();
    routeVMs.put(null, registryRoute());

    routes.stream()
        .map(route -> {
            RouteVM routeVM = new RouteVM();
            routeVM.setPath(route.getFullPath());
            routeVM.setPrefix(route.getPrefix());
            routeVM.setAppName(extractName(route.getId()));
            routeVM.setServiceId(route.getId());
            routeVM.setServiceInstances(discoveryClient.getInstances(route.getId()));

            return routeVM;
        })
        // we don't need the service sets. They come in as of eureka.fetch-registry=true, which is needed for requests against UAA
        .filter(routeVM -> routeVM.getServiceInstances() == null || routeVM.getServiceInstances().isEmpty())
        .forEach(route -> routeVMs.put(route.getServiceId(), route));

    fillStatus(routeVMs);

    return new ResponseEntity<>(new ArrayList<>(routeVMs.values()), HttpStatus.OK);
}
 
示例4
/**
 * Fill all Routes with each instance status.
 */
private void fillStatus(Map<String, RouteVM> routeVMs) {
    if (routeVMs != null && !routeVMs.isEmpty()) {
        zuulProperties.getRoutes().values().forEach(oneRoute -> {
            if (oneRoute instanceof ZuulRouteDTO) {
                routeVMs.get(oneRoute.getId()).setStatus(((ZuulRouteDTO) oneRoute).getStatus());
            }
        });
    }
}
 
示例5
/**
 * Fill all Routes with each instance status.
 */
private void fillStatus(Map<String, RouteVM> routeVMs) {
    if(routeVMs != null && !routeVMs.isEmpty()) {
        zuulProperties.getRoutes().values().forEach(oneRoute -> {
            if(oneRoute instanceof ZuulRouteDTO){
                routeVMs.get(oneRoute.getId()).setStatus(((ZuulRouteDTO) oneRoute).getStatus());
            }
        });
    }
}
 
示例6
/**
 * Fill all Routes with each instance status.
 */
private void fillStatus(Map<String, RouteVM> routeVMs) {
    if (routeVMs != null && !routeVMs.isEmpty()) {
        zuulProperties.getRoutes().values().forEach(oneRoute -> {
            if (oneRoute instanceof ZuulRouteDTO) {
                routeVMs.get(oneRoute.getId()).setStatus(((ZuulRouteDTO) oneRoute).getStatus());
            }
        });
    }
}
 
示例7
/**
 * Return the registry routeVM
 */
private RouteVM registryRoute() {
    return new RouteVM("/**", null, null, registryName, InstanceInfo.InstanceStatus.UP.toString(), null);
}
 
示例8
/**
 * Return the registry routeVM
 */
private RouteVM registryRoute() {
    return new RouteVM("/**", null, null, registryName, InstanceInfo.InstanceStatus.UP.toString(), null);
}
 
示例9
/**
 * Return the registry routeVM
 */
private RouteVM registryRoute() {
    return new RouteVM("/**", null, null, registryName, InstanceInfo.InstanceStatus.UP.toString(), null);
}