release new ver (#87)

Author: alissa-tung

Cargo.lock

@@ -11,10 +11,10 @@ readme = "README.md"
 keywords = ["hstreamdb", "streaming-database", "database-client"]
 
 [dependencies]
-prost = "0.11.0"
-prost-types = "0.11.1"
-tonic = "0.8.2"
+prost = "0.11.5"
+prost-types = "0.11.5"
+tonic = "0.8.3"
 workspace-hack = { version = "0.1", path = "../utils/workspace-hack" }
 
 [build-dependencies]
-tonic-build = "0.8.0"
+tonic-build = "0.8.4"

src/hstreamdb-pb/Cargo.toml

@@ -11,29 +11,29 @@ readme = "README.md"
 keywords = ["hstreamdb", "streaming-database", "database-client"]
 
 [dependencies]
-thiserror = "1.0.34"
+thiserror = "1.0.38"
 log = "0.4.17"
 
-flate2 = "1.0.24"
+flate2 = "1.0.25"
 zstd = "0.11.2"
 
 num-bigint = "0.4.3"
 num-traits = "0.2.15"
-md-5 = "0.10.1"
+md-5 = "0.10.5"
 
-hstreamdb-pb = { version = "0.2.0", path = "../hstreamdb-pb/" }
-prost-types = "0.11.1"
+hstreamdb-pb = { version = "0.2.1", path = "../hstreamdb-pb/" }
+prost-types = "0.11.5"
 
-prost = "0.11.0"
-tokio = { version = "1.21.0", features = ["rt-multi-thread", "parking_lot"] }
-tokio-stream = "0.1.9"
-tonic = { version = "0.8.2", features = ["tls"] }
-url = "2.2.2"
+prost = "0.11.5"
+tokio = { version = "1.23.0", features = ["rt-multi-thread", "parking_lot"] }
+tokio-stream = "0.1.11"
+tonic = { version = "0.8.3", features = ["tls"] }
+url = "2.3.1"
 workspace-hack = { version = "0.1", path = "../utils/workspace-hack" }
 
 [dev-dependencies]
 hstreamdb-test-utils = { path = "../utils/hstreamdb-test-utils" }
 
-anyhow = "1.0.62"
-env_logger = "0.9.0"
+anyhow = "1.0.68"
+env_logger = "0.9.3"
 rand = "0.8.5"

src/hstreamdb/Cargo.toml

@@ -148,7 +148,7 @@ mod tests {
             .unwrap();
 
         tokio::spawn(async move {
-            let mut appender = appender;
+            let appender = appender;
             for _ in 0..5000 {
                 appender
                     .append(Record {

src/hstreamdb/src/flow_controller.rs

@@ -65,7 +65,7 @@ async fn test_consumer() {
     for _ in 0..10 {
         let appender = appender.clone();
         let join_handle = tokio::spawn(async move {
-            let mut appender = appender;
+            let appender = appender;
             let mut results = Vec::new();
 
             for _ in 0..100 {

src/hstreamdb/tests/consumer_test.rs

@@ -53,7 +53,7 @@ async fn test_producer() {
     for _ in 0..10 {
         let appender = appender.clone();
         let join_handle = tokio::spawn(async move {
-            let mut appender = appender;
+            let appender = appender;
             let mut results = Vec::new();
 
             for _ in 0..100 {

src/hstreamdb/tests/producer_test.rs

@@ -5,8 +5,8 @@ edition = "2021"
 
 [dependencies]
 log = "0.4.17"
-env_logger = "0.9.0"
+env_logger = "0.9.3"
 
-anyhow = "1.0.62"
+anyhow = "1.0.68"
 rand = "0.8.5"
 workspace-hack = { version = "0.1", path = "../workspace-hack" }

src/utils/hstreamdb-test-utils/Cargo.toml

@@ -15,15 +15,14 @@ publish = false
 ### BEGIN HAKARI SECTION
 [dependencies]
 bytes = { version = "1", features = ["std"] }
-getrandom = { version = "0.2", default-features = false, features = ["js", "js-sys", "rdrand", "std", "wasm-bindgen"] }
 indexmap = { version = "1", default-features = false, features = ["std"] }
 log = { version = "0.4", default-features = false, features = ["std"] }
 prost = { version = "0.11", features = ["prost-derive", "std"] }
 prost-types = { version = "0.11", features = ["std"] }
 rand = { version = "0.8", features = ["alloc", "getrandom", "libc", "rand_chacha", "small_rng", "std", "std_rng"] }
 regex = { version = "1", features = ["aho-corasick", "memchr", "perf", "perf-cache", "perf-dfa", "perf-inline", "perf-literal", "std", "unicode", "unicode-age", "unicode-bool", "unicode-case", "unicode-gencat", "unicode-perl", "unicode-script", "unicode-segment"] }
 regex-syntax = { version = "0.6", features = ["unicode", "unicode-age", "unicode-bool", "unicode-case", "unicode-gencat", "unicode-perl", "unicode-script", "unicode-segment"] }
-tokio = { version = "1", features = ["bytes", "io-std", "io-util", "libc", "macros", "memchr", "mio", "net", "num_cpus", "once_cell", "parking_lot", "rt", "rt-multi-thread", "socket2", "sync", "time", "tokio-macros"] }
+tokio = { version = "1", features = ["bytes", "io-std", "io-util", "libc", "macros", "memchr", "mio", "net", "num_cpus", "parking_lot", "rt", "rt-multi-thread", "socket2", "sync", "time", "tokio-macros"] }
 tonic = { version = "0.8", features = ["async-trait", "axum", "channel", "codegen", "h2", "hyper", "hyper-timeout", "prost", "prost-derive", "prost1", "rustls-pemfile", "tls", "tokio", "tokio-rustls", "tower", "tracing-futures", "transport"] }
 
 [build-dependencies]

src/utils/workspace-hack/Cargo.toml

@@ -11,12 +11,12 @@ workspace-hack = { version = "0.1", path = "../../utils/workspace-hack" }
 hstreamdb = { path = "../../hstreamdb" }
 
 log = "0.4.17"
-env_logger = "0.9.0"
+env_logger = "0.9.3"
 
-once_cell = "1.14.0"
+once_cell = "1.17.0"
 rustler = "0.26.0"
-tokio = { version = "1.21.0", features = ["rt-multi-thread", "parking_lot"] }
+tokio = { version = "1.23.0", features = ["rt-multi-thread", "parking_lot"] }
 tokio-stream = "0.1.11"
 
-prost = "0.11.0"
-tonic = "0.8.2"
+prost = "0.11.5"
+tonic = "0.8.3"

src/x/hstreamdb-erl-nifs/Cargo.toml

@@ -33,7 +33,7 @@ rustler::atoms! {
     create_stream_reply,
     create_subscription_reply,
     earliest, latest,
-    start_producer_reply, stop_producer_reply,
+    start_producer_reply,
     append_reply, await_append_result_reply,
     start_streaming_fetch_reply, streaming_fetch,
     ack_reply,