public Mono filter()

in src/main/java/com/epam/digital/data/platform/gateway/filter/KubernetesUrlMappingGatewayFilter.java [46:55]


  public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    log.info("Adding target registry to request url");
    Map<String, String> pathVariables =
        exchange.getAttribute(ServerWebExchangeUtils.URI_TEMPLATE_VARIABLES_ATTRIBUTE);
    Route preconfiguredRoute = exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_ROUTE_ATTR);
    Route routeWithRegistryHost =
        createRouteWithUrl(pathVariables.get(REGISTRY_NAME_URL_PATH_VARIABLE), preconfiguredRoute);
    exchange.getAttributes().put(ServerWebExchangeUtils.GATEWAY_ROUTE_ATTR, routeWithRegistryHost);
    return chain.filter(exchange);
  }