Some minor API improvements

Signed-off-by: Heinz N. Gies <[email protected]>
tremor-rs · Apr 9, 2024 · 1262e36 · 1262e36
1 parent 931da7c
commit 1262e36
Show file tree

Hide file tree

Showing 24 changed files with 95 additions and 105 deletions.
diff --git a/.github/scripts/install-docker-images.sh b/.github/scripts/install-docker-images.sh
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/tremor-connectors-aws/Cargo.toml b/tremor-connectors-aws/Cargo.toml
@@ -18,7 +18,7 @@ tremor-config = { path = "../tremor-config" }
 async-trait = { version = "0.1", default-features = false }
 serde = { version = "1.0", default-features = false, features = ["derive"] }
 anyhow = { version = "1", default-features = false }
-async-channel = { version = "1.9", default-features = false }
+async-channel = { version = "2", default-features = false }
 thiserror = { version = "1", default-features = false }
 tokio = { version = "1.34", default-features = false }
 log = { version = "0.4", default-features = false }

diff --git a/tremor-connectors-aws/tests/aws/streamer.rs b/tremor-connectors-aws/tests/aws/streamer.rs
@@ -255,7 +255,7 @@ async fn connector_s3_consistent() -> anyhow::Result<()> {
 }
 
 async fn send_to_sink(harness: &Harness, event: &Event) -> anyhow::Result<()> {
-    harness.send_to_sink(event.clone(), IN).await?;
+    harness.send_to_sink(event.clone()).await?;
     Ok(())
 }
 

diff --git a/tremor-connectors-gcp/Cargo.toml b/tremor-connectors-gcp/Cargo.toml
@@ -25,8 +25,7 @@ log = { version = "0.4", default-features = true }
 serde = { version = "1.0", default-features = true, features = ["derive"] }
 thiserror = { version = "1", default-features = true }
 
-bytes = { version = "0.5", default-features = true }
-
+bytes = { version = "1.6", default-features = true }
 googapis = { version = "0.6", default-features = true, features = [
     "google-pubsub-v1",
     "google-cloud-bigquery-storage-v1",

diff --git a/tremor-connectors-gcp/tests/gcp/gpub.rs b/tremor-connectors-gcp/tests/gcp/gpub.rs
@@ -150,7 +150,7 @@ async fn simple_publish() -> anyhow::Result<()> {
             data: (Value::String(format!("Event {i}").into()), literal!({})).into(),
             ..Event::default()
         };
-        harness.send_to_sink(event, IN).await?;
+        harness.send_to_sink(event).await?;
     }
 
     let mut received_messages = HashSet::new();
@@ -257,7 +257,7 @@ async fn simple_publish_with_timeout() -> anyhow::Result<()> {
         data: (Value::from("Event X"), literal!({})).into(),
         ..Event::default()
     };
-    harness.send_to_sink(event, IN).await?;
+    harness.send_to_sink(event).await?;
     timeout(
         Duration::from_secs(10),
         harness.wait_for_state(State::Failed),