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);
}