dynamic_modules: add examples for network & listener modules

Signed-off-by: Rohit Agrawal <rohit.agrawal@databricks.com>

Author: agrawroh

Dockerfile

@@ -46,7 +46,7 @@ RUN CC="zig cc -target aarch64-linux-gnu" CXX="zig c++ -target aarch64-linux-gnu
 RUN CC="zig cc -target x86_64-linux-gnu" CXX="zig c++ -target x86_64-linux-gnu" CGO_ENABLED=1 GOARCH=amd64 go build -buildmode=c-shared -o /build/amd64_libgo_module.so .
 
 ##### Build the final image #####
-FROM envoyproxy/envoy:v1.36.2 AS envoy
+FROM envoyproxy/envoy:v1.37.0 AS envoy
 ARG TARGETARCH
 ENV ENVOY_DYNAMIC_MODULES_SEARCH_PATH=/usr/local/lib
 COPY --from=rust_builder /build/${TARGETARCH}_librust_module.so /usr/local/lib/librust_module.so

ENVOY_VERSION

@@ -1 +1 @@
-dc2d3098ae5641555f15c71d5bb5ce0060a8015c
+6d9bb7d9a85d616b220d1f8fe67b61f82bbdb8d3

rust/Cargo.lock

@@ -1,4 +1,3 @@
-
 [package]
 name = "envoy-proxy-dynamic-modules-rust-sdk-examples"
 version = "0.1.0"
@@ -8,7 +7,7 @@ repository = "https://github.com/envoyproxy/dynamic-modules-example"
 
 [dependencies]
 # The SDK version must match the Envoy version due to the strict compatibility requirements.
-envoy-proxy-dynamic-modules-rust-sdk = { git = "https://github.com/envoyproxy/envoy", rev = "dc2d3098ae5641555f15c71d5bb5ce0060a8015c" }
+envoy-proxy-dynamic-modules-rust-sdk = { git = "https://github.com/envoyproxy/envoy", rev = "6d9bb7d9a85d616b220d1f8fe67b61f82bbdb8d3" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 rand = "0.9.0"
@@ -17,7 +16,8 @@ matchers = "0.2.0"
 [dev-dependencies]
 tempfile = "3.16.0"
 
+# Main library - HTTP filters (backward compatible)
 [lib]
 name = "rust_module"
 path = "src/lib.rs"
-crate-type = ["cdylib"]
+crate-type = ["cdylib", "rlib"]

rust/Cargo.toml

@@ -77,7 +77,7 @@ impl FilterConfig {
 
 impl<EHF: EnvoyHttpFilter> HttpFilterConfig<EHF> for FilterConfig {
     /// This is called for each new HTTP filter.
-    fn new_http_filter(&mut self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
+    fn new_http_filter(&self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
         let tx = self.tx.clone();
         Box::new(Filter {
             tx,

rust/src/http_access_logger.rs

@@ -31,7 +31,7 @@ impl FilterConfig {
 
 impl<EHF: EnvoyHttpFilter> HttpFilterConfig<EHF> for FilterConfig {
     /// This is called for each new HTTP filter.
-    fn new_http_filter(&mut self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
+    fn new_http_filter(&self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
         Box::new(Filter {
             request_headers: self.request_headers.clone(),
             remove_request_headers: self.remove_request_headers.clone(),

rust/src/http_header_mutation.rs

@@ -38,7 +38,7 @@ impl FilterConfig {
 
 impl<EHF: EnvoyHttpFilter> HttpFilterConfig<EHF> for FilterConfig {
     /// This is called for each new HTTP filter.
-    fn new_http_filter(&mut self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
+    fn new_http_filter(&self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
         Box::new(Filter {
             version: self.config.version.clone(),
             start_time: None,

rust/src/http_metrics.rs

@@ -21,7 +21,7 @@ impl FilterConfig {
 
 impl<EHF: EnvoyHttpFilter> HttpFilterConfig<EHF> for FilterConfig {
     /// This is called for each new HTTP filter.
-    fn new_http_filter(&mut self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
+    fn new_http_filter(&self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
         Box::new(Filter {})
     }
 }

rust/src/http_passthrough.rs

@@ -18,7 +18,7 @@ impl FilterConfig {
 
 impl<EHF: EnvoyHttpFilter> HttpFilterConfig<EHF> for FilterConfig {
     /// This is called for each new HTTP filter.
-    fn new_http_filter(&mut self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
+    fn new_http_filter(&self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
         Box::new(Filter {})
     }
 }
@@ -37,7 +37,7 @@ impl<EHF: EnvoyHttpFilter> HttpFilter<EHF> for Filter {
     ) -> abi::envoy_dynamic_module_type_on_http_filter_request_headers_status {
         let reject = rand::rng().random::<bool>();
         if reject {
-            envoy_filter.send_response(403, vec![], Some(b"Access forbidden"));
+            envoy_filter.send_response(403, vec![], Some(b"Access forbidden"), None);
             return abi::envoy_dynamic_module_type_on_http_filter_request_headers_status::StopIteration;
         }
         abi::envoy_dynamic_module_type_on_http_filter_request_headers_status::Continue

rust/src/http_random_auth.rs

@@ -30,7 +30,7 @@ impl FilterConfig {
 
 impl<EHF: EnvoyHttpFilter> HttpFilterConfig<EHF> for FilterConfig {
     /// This is called for each new HTTP filter.
-    fn new_http_filter(&mut self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
+    fn new_http_filter(&self, _envoy: &mut EHF) -> Box<dyn HttpFilter<EHF>> {
         Box::new(Filter {
             re: self.re.clone(),
         })
@@ -61,7 +61,7 @@ impl<EHF: EnvoyHttpFilter> HttpFilter<EHF> for Filter {
         // [`EnvoyMutBuffer`]s. Each [`EnvoyMutBuffer`] is a mutable buffer that can be
         // used to read the body data.
         let data = envoy_filter
-            .get_request_body()
+            .get_buffered_request_body()
             .expect("Failed to get request body");
         let mut body_reader = BodyReader::new(data);
         let matched = self
@@ -70,7 +70,7 @@ impl<EHF: EnvoyHttpFilter> HttpFilter<EHF> for Filter {
             .expect("Failed to do regex match");
         if matched {
             // If the regex matches, we send a 403 response.
-            envoy_filter.send_response(403, vec![], Some(b"Access forbidden"));
+            envoy_filter.send_response(403, vec![], Some(b"Access forbidden"), None);
             return abi::envoy_dynamic_module_type_on_http_filter_request_body_status::StopIterationNoBuffer;
         }
         abi::envoy_dynamic_module_type_on_http_filter_request_body_status::Continue
@@ -126,7 +126,7 @@ mod tests {
     #[test]
     /// This demonstrates how to write a test without Envoy using a mock provided by the SDK.
     fn test_filter() {
-        let mut filter_config = FilterConfig::new("Hello [Ww].+").unwrap();
+        let filter_config = FilterConfig::new("Hello [Ww].+").unwrap();
         let mut envoy_filter = MockEnvoyHttpFilter::new();
         let mut filter: Box<dyn HttpFilter<MockEnvoyHttpFilter>> =
             filter_config.new_http_filter(&mut envoy_filter);
@@ -136,7 +136,7 @@ mod tests {
 
         // End of stream and matching regex, so we should send a 403 response.
         envoy_filter
-            .expect_get_request_body()
+            .expect_get_buffered_request_body()
             .returning(|| {
                 static mut HELLO: [u8; 6] = *b"Hello ";
                 static mut WORLD: [u8; 6] = *b"World!";
@@ -148,14 +148,14 @@ mod tests {
             .times(1);
         envoy_filter
             .expect_send_response()
-            .withf(|status, _, _| *status == 403)
-            .returning(|_, _, _| {})
+            .withf(|status, _, _, _| *status == 403)
+            .returning(|_, _, _, _| {})
             .times(1);
         assert_eq!(filter.on_request_body(&mut envoy_filter, true), abi::envoy_dynamic_module_type_on_http_filter_request_body_status::StopIterationNoBuffer);
 
         // End of stream and not matching regex, so we should continue.
         envoy_filter
-            .expect_get_request_body()
+            .expect_get_buffered_request_body()
             .returning(|| {
                 static mut GOOD: [u8; 5] = *b"Good ";
                 static mut MORNING: [u8; 8] = *b"Morning!";