Skip to content

Commit

Permalink
Add name to consumer Redis clients
Browse files Browse the repository at this point in the history
  • Loading branch information
NathanFlurry committed Jan 15, 2024
1 parent aee886f commit c9d6a8d
Showing 1 changed file with 14 additions and 1 deletion.
15 changes: 14 additions & 1 deletion lib/chirp/worker/src/manager.rs
Original file line number Diff line number Diff line change
Expand Up @@ -110,11 +110,24 @@ where
// Create a dedicated connection to redis-chirp for blocking Redis requests
// that won't block other requests in the pool.
let url = std::env::var("REDIS_URL_PERSISTENT").expect("REDIS_URL_PERSISTENT");
let redis_chirp_conn = redis::Client::open(url)
let mut redis_chirp_conn = redis::Client::open(url)
.map_err(ManagerError::BuildRedis)?
.get_tokio_connection_manager()
.await
.map_err(ManagerError::BuildRedis)?;
let res = redis::cmd("CLIENT")
.arg("SETNAME")
.arg(format!("consumer:{}:{}", group, W::NAME))
.query_async::<_, ()>(&mut redis_chirp_conn)
.await;
match res {
Ok(_) => {
tracing::trace!("setname success");
}
Err(err) => {
tracing::error!(?err, "setname failed");
}
}

self.clone()
.worker_receiver(
Expand Down

0 comments on commit c9d6a8d

Please sign in to comment.