udp: add router for UDP proxy #18791
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,20 @@ | ||
| syntax = "proto3"; | ||
|
|
||
| package envoy.extensions.filters.udp.udp_proxy.v3; | ||
|
|
||
| import "udpa/annotations/status.proto"; | ||
| import "validate/validate.proto"; | ||
|
|
||
| option java_package = "io.envoyproxy.envoy.extensions.filters.udp.udp_proxy.v3"; | ||
| option java_outer_classname = "RouteProto"; | ||
| option java_multiple_files = true; | ||
| option go_package = "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/udp/udp_proxy/v3;udp_proxyv3"; | ||
| option (udpa.annotations.file_status).package_version_status = ACTIVE; | ||
|
|
||
| // [#protodoc-title: UDP proxy route configuration] | ||
| // UDP proxy :ref:`configuration overview <config_udp_listener_filters_udp_proxy>`. | ||
|
|
||
| message Route { | ||
| // Indicates the upstream cluster to which the request should be routed. | ||
| string cluster = 1 [(validate.rules).string = {min_len: 1}]; | ||
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,90 @@ | ||
| static_resources: | ||
| listeners: | ||
| - name: listener_0 | ||
| address: | ||
| socket_address: | ||
| protocol: UDP | ||
| address: 0.0.0.0 | ||
| port_value: 1234 | ||
| listener_filters: | ||
| - name: envoy.filters.udp_listener.udp_proxy | ||
| typed_config: | ||
| '@type': type.googleapis.com/envoy.extensions.filters.udp.udp_proxy.v3.UdpProxyConfig | ||
| stat_prefix: service | ||
| matcher: | ||
| # The outer matcher list matches source IP. | ||
| matcher_list: | ||
| matchers: | ||
| - predicate: | ||
| single_predicate: | ||
| input: | ||
| name: envoy.matching.inputs.source_ip | ||
| typed_config: | ||
| '@type': type.googleapis.com/envoy.extensions.matching.common_inputs.network.v3.SourceIPInput | ||
| value_match: | ||
| exact: 127.0.0.1 | ||
| on_match: | ||
| matcher: | ||
| # The inner matcher tree matches source port. | ||
| matcher_tree: | ||
| input: | ||
| name: envoy.matching.inputs.source_port | ||
| typed_config: | ||
| '@type': type.googleapis.com/envoy.extensions.matching.common_inputs.network.v3.SourcePortInput | ||
| exact_match_map: | ||
| map: | ||
| "80": | ||
| action: | ||
| name: route | ||
| typed_config: | ||
| '@type': type.googleapis.com/envoy.extensions.filters.udp.udp_proxy.v3.Route | ||
| cluster: udp_service | ||
| "443": | ||
| action: | ||
| name: route | ||
| typed_config: | ||
| '@type': type.googleapis.com/envoy.extensions.filters.udp.udp_proxy.v3.Route | ||
| cluster: udp_service2 | ||
| on_no_match: | ||
| action: | ||
| name: route | ||
| typed_config: | ||
| '@type': type.googleapis.com/envoy.extensions.filters.udp.udp_proxy.v3.Route | ||
| cluster: udp_service3 | ||
| clusters: | ||
| - name: service_udp | ||
| type: STATIC | ||
| lb_policy: ROUND_ROBIN | ||
| load_assignment: | ||
| cluster_name: service_udp | ||
| endpoints: | ||
| - lb_endpoints: | ||
| - endpoint: | ||
| address: | ||
| socket_address: | ||
| address: 127.0.0.1 | ||
| port_value: 1235 | ||
| - name: service_udp2 | ||
| type: STATIC | ||
| lb_policy: ROUND_ROBIN | ||
| load_assignment: | ||
| cluster_name: service_udp | ||
| endpoints: | ||
| - lb_endpoints: | ||
| - endpoint: | ||
| address: | ||
| socket_address: | ||
| address: 127.0.0.1 | ||
| port_value: 1236 | ||
| - name: service_udp3 | ||
| type: STATIC | ||
| lb_policy: ROUND_ROBIN | ||
| load_assignment: | ||
| cluster_name: service_udp | ||
| endpoints: | ||
| - lb_endpoints: | ||
| - endpoint: | ||
| address: | ||
| socket_address: | ||
| address: 127.0.0.1 | ||
| port_value: 1237 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,29 @@ | ||
| load( | ||
| "//bazel:envoy_build_system.bzl", | ||
| "envoy_cc_library", | ||
| "envoy_extension_package", | ||
| ) | ||
|
|
||
| licenses(["notice"]) # Apache 2 | ||
|
|
||
| envoy_extension_package() | ||
|
|
||
| envoy_cc_library( | ||
| name = "router_interface", | ||
| hdrs = ["router.h"], | ||
| ) | ||
|
|
||
| envoy_cc_library( | ||
| name = "router_lib", | ||
| srcs = ["router_impl.cc"], | ||
| hdrs = ["router_impl.h"], | ||
| deps = [ | ||
| ":router_interface", | ||
| "//source/common/common:empty_string", | ||
| "//source/common/matcher:matcher_lib", | ||
| "//source/common/matcher:validation_visitor_lib", | ||
| "//source/common/network/matching:data_impl_lib", | ||
| "//source/common/network/matching:inputs_lib", | ||
| "@envoy_api//envoy/extensions/filters/udp/udp_proxy/v3:pkg_cc_proto", | ||
| ], | ||
| ) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,46 @@ | ||
| #pragma once | ||
|
|
||
| #include <memory> | ||
| #include <string> | ||
| #include <vector> | ||
|
|
||
| #include "envoy/common/pure.h" | ||
| #include "envoy/network/address.h" | ||
|
|
||
| namespace Envoy { | ||
| namespace Extensions { | ||
| namespace UdpFilters { | ||
| namespace UdpProxy { | ||
| namespace Router { | ||
|
|
||
| /** | ||
| * The router which holds all clusters and determines the cluster which UDP data should be routed | ||
| * to. | ||
| */ | ||
| class Router { | ||
| public: | ||
| virtual ~Router() = default; | ||
|
|
||
| /** | ||
| * Based on the address of the incoming UDP data, determine the target route for the data. | ||
| * @return the cluster name or empty string if there is not matching route for the data. | ||
| */ | ||
| virtual const std::string | ||
| route(const Network::Address::InstanceConstSharedPtr destination_address, | ||
|
Member
There was a problem hiding this comment. Sorry I meant
Contributor
Author
There was a problem hiding this comment. In the caller method, we will get a const std::string& route = config_->route(*data.addresses_.local_, *data.addresses_.peer_); Do you think it is acceptable?
Contributor
Author
There was a problem hiding this comment. Fixed, I have updated all methods in the caller chain. |
||
| const Network::Address::InstanceConstSharedPtr source_address) const PURE; | ||
|
|
||
| /** | ||
| * Returns all cluster names in the router. The UDP proxy filter requires every cluster name for | ||
| * initialization which will call this method on construction. | ||
| * @return vector of all cluster names. | ||
| */ | ||
| virtual const std::vector<std::string>& allClusterNames() const PURE; | ||
| }; | ||
|
|
||
| using RouterConstSharedPtr = std::shared_ptr<const Router>; | ||
|
|
||
| } // namespace Router | ||
| } // namespace UdpProxy | ||
| } // namespace UdpFilters | ||
| } // namespace Extensions | ||
| } // namespace Envoy | ||
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.