chore: update cloudevents-sdk to 0.7 (#176)

ce-rust · Oct 2, 2023 · a5757ea · a5757ea
1 parent 488f0db
commit a5757ea
Show file tree

Hide file tree

Showing 16 changed files with 255 additions and 342 deletions.
diff --git a/cerk/Cargo.toml b/cerk/Cargo.toml
@@ -16,7 +16,7 @@ edition = "2021"
 
 [dependencies]
 log = "0.4.0"
-cloudevents-sdk = "0.3.0"
+cloudevents-sdk = "0.7"
 strum_macros = "0.19.4"
 anyhow = "1.0"
 serde = { version = "=1.0.118" }
diff --git a/cerk/src/kernel/broker_event.rs b/cerk/src/kernel/broker_event.rs
@@ -3,7 +3,7 @@ use crate::kernel::outgoing_processing_result::ProcessingResult;
 use crate::kernel::CloudEventRoutingArgs;
 use crate::runtime::channel::BoxedSender;
 use crate::runtime::{InternalServerFnRef, InternalServerId};
-use cloudevents::Event;
+use cloudevents::event::Event;
 use serde::Serialize;
 use std::fmt;
 

diff --git a/cerk_port_amqp/Cargo.toml b/cerk_port_amqp/Cargo.toml
@@ -26,4 +26,4 @@ amq-protocol-types = "6.0.1"
 amq-protocol = { version = "6.0.1", features = [], default-features = false }
 anyhow = "1.0"
 async-std = "1.7.0"
-cloudevents-sdk = "0.3.0"
+cloudevents-sdk = "0.7"
diff --git a/cerk_port_dummies/Cargo.toml b/cerk_port_dummies/Cargo.toml
@@ -18,7 +18,7 @@ edition = "2021"
 log = "0.4.0"
 env_logger = "0.8"
 cerk = { version = "0.2", path = "../cerk" }
-cloudevents-sdk = "0.3.0"
+cloudevents-sdk = "0.7"
 chrono = "0.4"
 serde_json = "1.0"
 anyhow = "1.0"

diff --git a/cerk_port_dummies/src/port_printer.rs b/cerk_port_dummies/src/port_printer.rs
@@ -69,7 +69,7 @@ mod tests {
         OutgoingCloudEventProcessed, ProcessingResult,
     };
     use cerk_runtime_threading::channel::new_channel_with_size;
-    use cloudevents::Event;
+    use cloudevents::event::Event;
     use std::thread;
     use std::time::Duration;
 

diff --git a/cerk_port_mqtt/Cargo.toml b/cerk_port_mqtt/Cargo.toml
@@ -18,7 +18,7 @@ edition = "2021"
 log = "0.4"
 env_logger = "0.7"
 cerk = { version = "0.2", path = "../cerk" }
-cloudevents-sdk = "0.3"
+cloudevents-sdk = "0.7"
 serde_json = "1.0"
 paho-mqtt = { version="0.11", features=["bundled", "build_bindgen"], default-features = false}
 anyhow = "1.0"

diff --git a/cerk_port_mqtt/src/port_mqtt.rs b/cerk_port_mqtt/src/port_mqtt.rs
@@ -6,7 +6,8 @@ use cerk::kernel::{
 };
 use cerk::runtime::channel::{BoxedReceiver, BoxedSender};
 use cerk::runtime::{InternalServerFn, InternalServerFnRefStatic, InternalServerId};
-use cloudevents::{AttributesReader, Event};
+use cloudevents::event::Event;
+use cloudevents::AttributesReader;
 use paho_mqtt::{
     AsyncClient, ConnectOptionsBuilder, CreateOptionsBuilder, Message, PersistenceType,
 };

diff --git a/cerk_port_mqtt_mosquitto/Cargo.toml b/cerk_port_mqtt_mosquitto/Cargo.toml
@@ -19,7 +19,7 @@ log = "0.4"
 env_logger = "0.7"
 url = "2"
 cerk = { version = "0.2", path = "../cerk" }
-cloudevents-sdk = "0.3"
+cloudevents-sdk = "0.7"
 serde_json = "1.0"
 mosquitto-client-wrapper = "^0.3.1"
 anyhow = "1.0"
diff --git a/cerk_port_mqtt_mosquitto/src/port_mqtt.rs b/cerk_port_mqtt_mosquitto/src/port_mqtt.rs
@@ -6,7 +6,8 @@ use cerk::kernel::{
 };
 use cerk::runtime::channel::{BoxedReceiver, BoxedSender};
 use cerk::runtime::{InternalServerFn, InternalServerFnRefStatic, InternalServerId};
-use cloudevents::{AttributesReader, Event};
+use cloudevents::event::Event;
+use cloudevents::AttributesReader;
 use mosquitto_client_wrapper::Mosquitto;
 use serde_json;
 use std::collections::HashMap;

diff --git a/cerk_port_unix_socket/Cargo.toml b/cerk_port_unix_socket/Cargo.toml
@@ -20,7 +20,7 @@ edition = "2021"
 log = "0.4.0"
 env_logger = "0.7.1"
 cerk = { version = "0.2", path = "../cerk" }
-cloudevents-sdk = "0.3.0"
+cloudevents-sdk = "0.7"
 serde_json = "1.0.42"
 anyhow = "1.0"
 

diff --git a/cerk_port_unix_socket/src/port_input_unix_socket_json.rs b/cerk_port_unix_socket/src/port_input_unix_socket_json.rs
@@ -1,7 +1,7 @@
 use cerk::kernel::{BrokerEvent, CloudEventRoutingArgs, Config, IncomingCloudEvent};
 use cerk::runtime::channel::{BoxedReceiver, BoxedSender};
 use cerk::runtime::{InternalServerFn, InternalServerFnRefStatic, InternalServerId};
-use cloudevents::Event;
+use cloudevents::event::Event;
 use serde_json;
 use std::io::{BufRead, BufReader};
 use std::os::unix::net::{UnixListener, UnixStream};

diff --git a/cerk_port_unix_socket/src/port_output_unix_socket_json.rs b/cerk_port_unix_socket/src/port_output_unix_socket_json.rs
@@ -4,7 +4,7 @@ use cerk::kernel::{
 };
 use cerk::runtime::channel::{BoxedReceiver, BoxedSender};
 use cerk::runtime::{InternalServerFn, InternalServerFnRefStatic, InternalServerId};
-use cloudevents::Event;
+use cloudevents::event::Event;
 use serde_json;
 use std::io::Write;
 use std::os::unix::net::{UnixListener, UnixStream};
@@ -129,7 +129,7 @@ mod tests {
         OutgoingCloudEventProcessed, ProcessingResult,
     };
     use cerk_runtime_threading::channel::new_channel_with_size;
-    use cloudevents::Event;
+    use cloudevents::event::Event;
     use std::thread;
     use std::time::Duration;
 

diff --git a/cerk_router_broadcast/Cargo.toml b/cerk_router_broadcast/Cargo.toml
@@ -19,5 +19,5 @@ edition = "2021"
 [dependencies]
 log = "0.4.0"
 cerk = { version = "0.2", path = "../cerk" }
-cloudevents-sdk = "0.3.0"
+cloudevents-sdk = "0.7"
 anyhow = "1.0"
diff --git a/cerk_router_rule_based/Cargo.toml b/cerk_router_rule_based/Cargo.toml
@@ -19,7 +19,7 @@ edition = "2021"
 [dependencies]
 log = "0.4.0"
 cerk = { version = "0.2", path = "../cerk" }
-cloudevents-sdk = "0.3.0"
+cloudevents-sdk = "0.7"
 serde_json = "1.0.42"
 serde = "1.0.103"
 serde_derive = "1.0.103"