Draft: HTTPS Mux SessionState

bin/src/cli.rs

@@ -454,6 +454,8 @@ pub enum HttpFrontendCmd {
         method: Option<String>,
         #[clap(long = "tags", help = "Specify tag (key-value pair) to apply on front-end (example: 'key=value, other-key=other-value')", value_parser = parse_tags)]
         tags: Option<BTreeMap<String, String>>,
+        #[clap(help = "the frontend uses http2 with prio-knowledge")]
+        h2: Option<bool>,
     },
     #[clap(name = "remove")]
     Remove {

bin/src/ctl/command.rs

@@ -434,7 +434,7 @@ impl CommandManager {
                     if let Some(response_content) = response.content {
                         let certs = match response_content.content_type {
                             Some(ContentType::CertificatesWithFingerprints(certs)) => certs.certs,
-                            _ => bail!(format!("Wrong response content {:?}", response_content)),
+                            _ => bail!(format!("Wrong response content {response_content:?}")),
                         };
                         if certs.is_empty() {
                             bail!("No certificates match your request.");

bin/src/ctl/display.rs

@@ -611,7 +611,7 @@ pub fn print_cluster_responses(
     clusters_table.set_format(*prettytable::format::consts::FORMAT_BOX_CHARS);
     let mut header = vec![cell!("cluster id")];
     for worker_id in worker_responses.map.keys() {
-        header.push(cell!(format!("worker {}", worker_id)));
+        header.push(cell!(format!("worker {worker_id}")));
     }
     header.push(cell!("desynchronized"));
     clusters_table.add_row(Row::new(header));
@@ -659,14 +659,14 @@ pub fn print_certificates_by_worker(
     }
 
     for (worker_id, response_content) in response_contents.iter() {
-        println!("Worker {}", worker_id);
+        println!("Worker {worker_id}");
         match &response_content.content_type {
             Some(ContentType::CertificatesByAddress(list)) => {
                 for certs in list.certificates.iter() {
                     println!("\t{}:", certs.address);
 
                     for summary in certs.certificate_summaries.iter() {
-                        println!("\t\t{}", summary);
+                        println!("\t\t{summary}");
                     }
 
                     println!();

bin/src/ctl/request_builder.rs

@@ -202,6 +202,7 @@ impl CommandManager {
                 method,
                 cluster_id: route,
                 tags,
+                h2,
             } => self.send_request(
                 RequestType::AddHttpFrontend(RequestHttpFrontend {
                     cluster_id: route.into(),
@@ -214,6 +215,7 @@ impl CommandManager {
                         Some(tags) => tags,
                         None => BTreeMap::new(),
                     },
+                    h2: h2.unwrap_or(false),
                 })
                 .into(),
             ),
@@ -250,6 +252,7 @@ impl CommandManager {
                 method,
                 cluster_id: route,
                 tags,
+                h2,
             } => self.send_request(
                 RequestType::AddHttpsFrontend(RequestHttpFrontend {
                     cluster_id: route.into(),
@@ -262,6 +265,7 @@ impl CommandManager {
                         Some(tags) => tags,
                         None => BTreeMap::new(),
                     },
+                    h2: h2.unwrap_or(false),
                 })
                 .into(),
             ),

command/src/command.proto

@@ -161,6 +161,7 @@ message HttpsListenerConfig {
     // The tickets allow the client to resume a session. This protects the client
     // agains session tracking. Defaults to 4.
     required uint64 send_tls13_tickets = 20;
+    repeated AlpnProtocol alpn = 21;
 }
 
 // details of an TCP listener
@@ -221,6 +222,7 @@ message RequestHttpFrontend {
     required RulePosition position = 6 [default = TREE];
     // custom tags to identify the frontend in the access logs
     map<string, string> tags = 7;
+    required bool h2 = 8;
 }
 
 message RequestTcpFrontend {
@@ -339,6 +341,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;