examples: add cloud-rustls example

Author: muzarski

.github/workflows/serverless.yaml

@@ -31,8 +31,10 @@ jobs:
         run: rustup update
       - name: Check
         run: cargo check --verbose
-      - name: Run cloud example
+      - name: Run cloud-openssl example
         run: cargo run --example cloud-openssl -- $HOME/.ccm/serverless/config_data.yaml
+      - name: Run cloud-rustls example
+        run: cargo run --example cloud-rustls -- $HOME/.ccm/serverless/config_data.yaml
       - name: Run cloud tests
         run: CLOUD_CONFIG_PATH=$HOME/.ccm/serverless/config_data.yaml RUSTFLAGS="--cfg scylla_cloud_tests" RUST_LOG=trace cargo test --verbose
 

examples/Cargo.toml

@@ -121,6 +121,10 @@ path = "query_history.rs"
 name = "cloud-openssl"
 path = "cloud-openssl.rs"
 
+[[example]]
+name = "cloud-rustls"
+path = "cloud-rustls.rs"
+
 [[example]]
 name = "tls-openssl"
 path = "tls-openssl.rs"

examples/cloud-rustls.rs

@@ -0,0 +1,30 @@
+use std::env;
+use std::path::Path;
+
+use anyhow::Result;
+use scylla::client::session_builder::CloudSessionBuilder;
+use scylla::cloud::CloudTlsProvider;
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    println!("Connecting to SNI proxy as described in cloud config yaml ...");
+    let config_path = env::args()
+        .nth(1)
+        .unwrap_or("examples/config_data.yaml".to_owned());
+    let session = CloudSessionBuilder::new(Path::new(&config_path), CloudTlsProvider::Rustls023)
+        .unwrap()
+        .build()
+        .await
+        .unwrap();
+
+    session.query_unpaged("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}",
+                    &[]).await.unwrap();
+    session
+        .query_unpaged("DROP TABLE IF EXISTS examples_ks.cloud;", &[])
+        .await
+        .unwrap();
+
+    println!("Ok.");
+
+    Ok(())
+}