Move proxy::Server to Proxy and sessions::session to sessions

benches/throughput.rs

@@ -29,7 +29,7 @@ const PACKETS: &[&[u8]] = &[
 fn run_quilkin(port: u16, endpoint: SocketAddr) {
     std::thread::spawn(move || {
         let runtime = tokio::runtime::Runtime::new().unwrap();
-        let config = quilkin::Server::builder()
+        let config = quilkin::Config::builder()
             .port(port)
             .admin(Admin {
                 address: "[::]:0".parse().unwrap(),
@@ -38,7 +38,7 @@ fn run_quilkin(port: u16, endpoint: SocketAddr) {
             .build()
             .unwrap();
 
-        let server = quilkin::Server::try_from(config).unwrap();
+        let server = quilkin::Proxy::try_from(config).unwrap();
         runtime.block_on(async move {
             let (_shutdown_tx, shutdown_rx) = tokio::sync::watch::channel::<()>(());
             server.run(shutdown_rx).await.unwrap();

docs/src/filters.md

@@ -69,7 +69,7 @@ clusters:
 # ";
 # let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 2);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 # }
 ```
 

docs/src/filters/capture.md

@@ -48,7 +48,7 @@ clusters:
 # ";
 # let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 1);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 ```
 
 ### Configuration Options ([Rust Doc](../../api/quilkin/filters/capture/struct.Config.html))

docs/src/filters/compress.md

@@ -26,7 +26,7 @@ clusters:
 # ";
 # let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 1);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 ```
 
 The above example shows a proxy that could be used with a typical game client, where the original client data is

docs/src/filters/concatenate_bytes.md

@@ -26,7 +26,7 @@ clusters:
 # ";
 # let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 1);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 ```
 
 ### Configuration Options ([Rust Doc](../../api/quilkin/filters/concatenate_bytes/struct.Config.html))

docs/src/filters/debug.md

@@ -25,7 +25,7 @@ clusters:
 # ";
 # let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 1);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 ```
 
 ### Configuration Options ([Rust Doc](../../api/quilkin/filters/debug/struct.Config.html))

docs/src/filters/firewall.md

@@ -34,7 +34,7 @@ clusters:
 # ";
 # let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 1);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 ```
 
 ### Configuration Options ([Rust Doc](../../api/quilkin/filters/firewall/struct.Config.html))

docs/src/filters/load_balancer.md

@@ -25,7 +25,7 @@ clusters:
 # ";
 #   let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 1);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 # }
 ```
 

docs/src/filters/local_rate_limit.md

@@ -29,7 +29,7 @@ clusters:
 # ";
 #   let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 1);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 # }
 ```
 To configure a rate limiter, we specify the maximum rate at which the proxy is allowed to forward packets. In the example above, we configured the proxy to forward a maximum of 1000 packets per second).

docs/src/filters/match.md

@@ -39,7 +39,7 @@ filters:
 # ";
 # let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 2);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 ```
 <!--  ANCHOR_END: example -->
 

docs/src/filters/token_router.md

@@ -37,7 +37,7 @@ clusters:
 # ";
 # let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 1);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 ```
 
 View the [CaptureBytes](./capture.md) filter documentation for more details.
@@ -102,7 +102,7 @@ clusters:
 # ";
 # let config = quilkin::config::Config::from_reader(yaml.as_bytes()).unwrap();
 # assert_eq!(config.filters.load().len(), 2);
-# quilkin::Server::try_from(config).unwrap();
+# quilkin::Proxy::try_from(config).unwrap();
 ```
 
 On the game client side the [ConcatenateBytes](./concatenate_bytes.md) filter could also be used to add authentication

docs/src/filters/writing_custom_filters.md

@@ -73,7 +73,7 @@ impl StaticFilter for Greet {
 
 ## Running
 
-We can run the proxy using [`Server::TryFrom`][Server::TryFrom] function. Let's
+We can run the proxy using [`Proxy::TryFrom`][Proxy::TryFrom] function. Let's
 add a main function that does that. Quilkin relies on the [Tokio] async
 runtime, so we need to import that crate and wrap our main function with it.
 
@@ -243,7 +243,7 @@ filter. Try it out with the following configuration:
 [filter-factory-name]: ../../api/quilkin/filters/trait.FilterFactory.html#tymethod.name
 [FilterRegistry]: ../../api/quilkin/filters/struct.FilterRegistry.html
 [FilterRegistry::register]: ../../api/quilkin/filters/struct.FilterRegistry.html#method.register
-[Server::try_from]: ../../api/struct.Server.html#impl-TryFrom%3CConfig%3E
+[Proxy::try_from]: ../../api/struct.Proxy.html#impl-TryFrom%3CConfig%3E
 [CreateFilterArgs::config]: ../../api/quilkin/filters/prelude/struct.CreateFilterArgs.html#structfield.config
 [ConfigType::dynamic]: ../../api/quilkin/config/enum.ConfigType.html#variant.Dynamic
 [ConfigType::static]: ../../api/quilkin/config/enum.ConfigType.html#variant.Static

examples/quilkin-filter-example/src/main.rs

@@ -95,7 +95,7 @@ async fn main() -> quilkin::Result<()> {
     quilkin::filters::FilterRegistry::register(vec![Greet::factory()].into_iter());
 
     let (_shutdown_tx, shutdown_rx) = tokio::sync::watch::channel(());
-    let server: quilkin::Server = quilkin::Config::builder()
+    let server: quilkin::Proxy = quilkin::Config::builder()
         .port(7001)
         .filters(vec![quilkin::config::Filter {
             name: Greet::NAME.into(),

src/cli/run.rs

@@ -31,7 +31,7 @@ impl Run {
         let span = span!(Level::INFO, "source::run");
         let _enter = span.enter();
 
-        let server = crate::Server::try_from(config)?;
+        let server = crate::Proxy::try_from(config)?;
 
         #[cfg(target_os = "linux")]
         let mut sig_term_fut = signal::unix::signal(signal::unix::SignalKind::terminate())?;

src/lib.rs

@@ -37,7 +37,7 @@ pub mod xds;
 pub type Result<T, E = eyre::Error> = std::result::Result<T, E>;
 
 #[doc(inline)]
-pub use self::{cli::Cli, config::Config, proxy::Server};
+pub use self::{cli::Cli, config::Config, proxy::Proxy};
 
 pub use quilkin_macros::include_proto;