feat(trigger-redis): Add tracing to trigger-redis

Signed-off-by: Caleb Schoepp <[email protected]>

Author: calebschoepp

crates/trigger-redis/Cargo.toml

@@ -24,3 +24,6 @@ tokio = { version = "1.23", features = ["full"] }
 
 [dev-dependencies]
 spin-testing = { path = "../testing" }
+
+[lints]
+workspace = true

crates/trigger-redis/src/lib.rs

@@ -11,6 +11,7 @@ use spin_core::{async_trait, InstancePre};
 use spin_trigger::{cli::NoArgs, TriggerAppEngine, TriggerExecutor};
 use std::collections::HashMap;
 use std::sync::Arc;
+use tracing::{instrument, Level};
 
 use crate::spin::SpinRedisExecutor;
 
@@ -110,6 +111,9 @@ impl TriggerExecutor for RedisTrigger {
 
 impl RedisTrigger {
     // Handle the message.
+    #[instrument(name = "spin_trigger_redis.handle_message", skip(self, channel_components, msg),
+        err(level = Level::INFO), fields(otel.name = format!("{} receive", msg.get_channel_name()),
+        otel.kind = "consumer", messaging.operation = "receive", messaging.system = "redis"))]
     async fn handle(
         &self,
         address: &str,

crates/trigger-redis/src/spin.rs

@@ -3,6 +3,7 @@ use async_trait::async_trait;
 use spin_core::Instance;
 use spin_trigger::TriggerAppEngine;
 use spin_world::v1::redis_types::{Error, Payload};
+use tracing::{instrument, Level};
 
 use crate::{RedisExecutor, RedisTrigger, Store};
 
@@ -11,6 +12,7 @@ pub struct SpinRedisExecutor;
 
 #[async_trait]
 impl RedisExecutor for SpinRedisExecutor {
+    #[instrument(name = "spin_trigger_redis.execute_wasm", skip(self, engine, payload), err(level = Level::INFO), fields(otel.name = format!("execute_wasm_component {}", component_id)))]
     async fn execute(
         &self,
         engine: &TriggerAppEngine<RedisTrigger>,