Draft: introduce multiplexed SessionState to handle heterogeneous HTTP Sessions

bin/Cargo.toml

@@ -5,7 +5,7 @@ repository = "https://github.com/sozu-proxy/sozu"
 readme = "README.md"
 documentation = "https://docs.rs/sozu"
 homepage = "https://sozu.io"
-version = "1.0.4"
+version = "1.1.0-rc.2"
 license = "AGPL-3.0"
 authors = [
   "Geoffroy Couprie <[email protected]>",
@@ -34,8 +34,8 @@ tempfile = "^3.10.1"
 termion = "^4.0.0"
 thiserror = "^1.0.61"
 
-sozu-command-lib = { path = "../command", version = "^1.0.4" }
-sozu-lib = { path = "../lib", version = "^1.0.4" }
+sozu-command-lib = { path = "../command", version = "^1.1.0-rc.2" }
+sozu-lib = { path = "../lib", version = "1.1.0-rc.2" }
 
 [target.'cfg(target_os="linux")'.dependencies]
 num_cpus = "^1.16.0"

bin/config.toml

@@ -324,7 +324,8 @@ frontends = [
 # - weight: weight used by the load balancing algorithm
 # - sticky-id: sticky session identifier
 backends = [
-    { address = "127.0.0.1:1026", backend_id = "the-backend-to-my-app" }
+    { address = "127.0.0.1:1026", backend_id = "back26" },
+    { address = "127.0.0.1:1027", backend_id = "back27" }
 ]
 
 # this is an example of a routing configuration for the TCP proxy

bin/src/cli.rs

@@ -180,7 +180,10 @@ pub enum SubCmd {
         #[clap(subcommand)]
         cmd: ConfigCmd,
     },
-    #[clap(name = "events", about = "receive sozu events about the status of backends")]
+    #[clap(
+        name = "events",
+        about = "receive sozu events about the status of backends"
+    )]
     Events,
 }
 
@@ -296,6 +299,11 @@ pub enum ClusterCmd {
             help = "Configures the load balancing policy. Possible values are 'roundrobin', 'random' or 'leastconnections'"
         )]
         load_balancing_policy: LoadBalancingAlgorithms,
+        #[clap(
+            long = "http2",
+            help = "the backends of this cluster use http2 prio-knowledge"
+        )]
+        h2: bool,
     },
 }
 

bin/src/ctl/request_builder.rs

@@ -150,6 +150,7 @@ impl CommandManager {
                 send_proxy,
                 expect_proxy,
                 load_balancing_policy,
+                h2,
             } => {
                 let proxy_protocol = match (send_proxy, expect_proxy) {
                     (true, true) => Some(ProxyProtocolConfig::RelayHeader),
@@ -164,7 +165,9 @@ impl CommandManager {
                         https_redirect,
                         proxy_protocol: proxy_protocol.map(|pp| pp as i32),
                         load_balancing: load_balancing_policy as i32,
-                        ..Default::default()
+                        http2: h2,
+                        load_metric: None,
+                        answer_503: None,
                     })
                     .into(),
                 )

command/Cargo.toml

@@ -5,7 +5,7 @@ repository = "https://github.com/sozu-proxy/sozu"
 readme = "README.md"
 documentation = "https://docs.rs/sozu-command-lib"
 homepage = "https://sozu.io"
-version = "1.0.4"
+version = "1.1.0-rc.2"
 license = "LGPL-3.0"
 authors = [
   "Geoffroy Couprie <[email protected]>",

command/src/command.proto

@@ -162,6 +162,7 @@ message HttpsListenerConfig {
     // agains session tracking. Defaults to 4.
     required uint64 send_tls13_tickets = 20;
     optional CustomHttpAnswers http_answers = 21;
+    repeated AlpnProtocol alpn = 22;
 }
 
 // details of an TCP listener
@@ -366,6 +367,11 @@ enum TlsVersion {
     TLS_V1_3 = 5;
 }
 
+enum AlpnProtocol {
+    Http11 = 0;
+    H2 = 1;
+}
+
 // A cluster is what binds a frontend to backends with routing rules
 message Cluster {
     required string cluster_id = 1;
@@ -376,6 +382,7 @@ message Cluster {
     required LoadBalancingAlgorithms load_balancing = 5 [default = ROUND_ROBIN];
     optional string answer_503 = 6;
     optional LoadMetric load_metric = 7;
+    required bool http2 = 8;
 }
 
 enum LoadBalancingAlgorithms {