first commit

Author: piodul

.gitignore

@@ -0,0 +1,4 @@
+.vscode/
+/scylla-cdc/target
+/target
+Cargo.lock

Cargo.toml

@@ -0,0 +1,5 @@
+[workspace]
+members = [
+    "scylla-cdc",
+    "scylla-cdc-printer",
+]

scylla-cdc-printer/Cargo.toml

@@ -0,0 +1,11 @@
+[package]
+name = "scylla-cdc-replicator"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+scylla = "0.2.1"
+scylla-cdc = { version = "0.1.0", path = "../scylla-cdc" }
+tokio = { version = "1.1.0", features = ["full"] }

scylla-cdc-printer/src/main.rs

@@ -0,0 +1,11 @@
+use std::error::Error;
+use std::time::Duration;
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn Error>> {
+    println!("Hello");
+    tokio::time::sleep(Duration::from_secs(1)).await;
+
+    println!("Printer");
+    Ok(())
+}

scylla-cdc/Cargo.toml

@@ -0,0 +1,10 @@
+[package]
+name = "scylla-cdc"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+scylla = "0.2.1"
+tokio = { version = "1.1.0", features = ["rt", "io-util", "net", "time", "macros", "sync"] }

scylla-cdc/src/lib.rs

@@ -0,0 +1,8 @@
+#[cfg(test)]
+mod tests {
+    #[test]
+    fn it_works() {
+        let result = 2 + 2;
+        assert_eq!(result, 4);
+    }
+}