Use tracing crate to log outcome of each call to push_events

Cargo.toml

@@ -24,6 +24,7 @@ serde = "1.0.196"
 serde_bytes = "0.11.14"
 tokio = "1.36.0"
 tokio-util = "0.7.10"
+tracing = "0.1.40"
 
 [patch.crates-io]
 pocket-ic = { git = "https://github.com/dfinity/ic", rev = "044cfd5147fc97d7e5a214966941b6580c325d72" }

client/cdk_runtime/Cargo.toml

@@ -13,3 +13,4 @@ ic-cdk-timers.workspace = true
 ic_principal.workspace = true
 rand.workspace = true
 serde.workspace = true
+tracing.workspace = true

client/cdk_runtime/src/lib.rs

@@ -6,6 +6,7 @@ use rand::rngs::StdRng;
 use rand::{Rng, SeedableRng};
 use serde::{Deserialize, Deserializer, Serialize, Serializer};
 use std::time::Duration;
+use tracing::error;
 
 pub struct CdkRuntime {
     rng: StdRng,
@@ -50,11 +51,14 @@ async fn flush_async<F: FnOnce()>(
     events: Vec<IdempotentEvent>,
     trigger_retry: F,
 ) {
-    if ic_cdk::call::<_, ()>(canister_id, "push_events", (PushEventsArgs { events },))
-        .await
-        .is_err()
+    let events_len = events.len();
+    if let Err(error) =
+        ic_cdk::call::<_, ()>(canister_id, "push_events", (PushEventsArgs { events },)).await
     {
         trigger_retry();
+        error!(?error, %canister_id, events = events_len, "Failed to call 'push_events'");
+    } else {
+        error!(%canister_id, events = events_len, "Successfully pushed events");
     }
 }
 

client/src/lib.rs

@@ -8,10 +8,12 @@ use std::time::Duration;
 const DEFAULT_FLUSH_DELAY: Duration = Duration::from_secs(300);
 const DEFAULT_MAX_BATCH_SIZE: u32 = 1000;
 
-pub struct Client<R> {
+pub struct EventSinkClient<R> {
     inner: Arc<Mutex<ClientInner<R>>>,
 }
 
+type Client<R> = EventSinkClient<R>;
+
 #[derive(Serialize, Deserialize)]
 struct ClientInner<R> {
     event_sink_canister_id: Principal,