biump

Author: ovadiagal

rust/src/http_access_logger.rs

@@ -187,9 +187,12 @@ mod tests {
         envoy_filter
             .expect_get_request_headers()
             .returning(|| vec![(EnvoyBuffer::new(b"host"), EnvoyBuffer::new(b"example.com"))]);
-        envoy_filter
-            .expect_get_response_headers()
-            .returning(|| vec![(EnvoyBuffer::new(b"content-length"), EnvoyBuffer::new(b"123"))]);
+        envoy_filter.expect_get_response_headers().returning(|| {
+            vec![(
+                EnvoyBuffer::new(b"content-length"),
+                EnvoyBuffer::new(b"123"),
+            )]
+        });
         access_logger_filter.on_request_headers(&mut envoy_filter, false);
         access_logger_filter.on_response_headers(&mut envoy_filter, false);
 

rust/src/lib.rs

@@ -60,7 +60,14 @@ pub mod listener_ip_allowlist;
 pub mod listener_sni_router;
 pub mod listener_tls_detector;
 
-declare_init_functions!(init, new_http_filter_config_fn);
+// DNS gateway filter examples.
+pub mod dns_gateway;
+
+declare_all_init_functions!(init,
+    http: new_http_filter_config_fn,
+    network: new_network_filter_config_fn,
+    udp_listener: new_udp_listener_filter_config_fn
+);
 
 /// This implements the [`envoy_proxy_dynamic_modules_rust_sdk::ProgramInitFunction`].
 ///
@@ -102,3 +109,33 @@ fn new_http_filter_config_fn<EC: EnvoyHttpFilterConfig, EHF: EnvoyHttpFilter>(
         _ => panic!("Unknown filter name: {filter_name}"),
     }
 }
+
+fn new_network_filter_config_fn<EC: EnvoyNetworkFilterConfig, ENF: EnvoyNetworkFilter>(
+    _envoy_filter_config: &mut EC,
+    filter_name: &str,
+    filter_config: &[u8],
+) -> Option<Box<dyn NetworkFilterConfig<ENF>>> {
+    match filter_name {
+        "cache_lookup" => Some(Box::new(
+            dns_gateway::cache_lookup::CacheLookupFilterConfig::new(filter_config),
+        )),
+        _ => panic!("Unknown network filter name: {filter_name}"),
+    }
+}
+
+fn new_udp_listener_filter_config_fn<
+    EC: EnvoyUdpListenerFilterConfig,
+    ELF: EnvoyUdpListenerFilter,
+>(
+    _envoy_filter_config: &mut EC,
+    filter_name: &str,
+    filter_config: &[u8],
+) -> Option<Box<dyn UdpListenerFilterConfig<ELF>>> {
+    match filter_name {
+        "dns_gateway" => {
+            let config = dns_gateway::DnsGatewayFilterConfig::new(filter_config)?;
+            Some(Box::new(config))
+        }
+        _ => panic!("Unknown UDP listener filter name: {filter_name}"),
+    }
+}