logos-co
/
Overwatch
mirror of https://github.com/logos-co/Overwatch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Formatting.

This commit is contained in:
Alejandro Cabeza Romero 2024-12-19 16:28:00 +01:00
parent f8a0cc2681
commit 7efe5e2461
No known key found for this signature in database
GPG Key ID: DA3D14AE478030FD
3 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
overwatch-rs/src/overwatch/handle.rs
View File

@ -6,9 +6,9 @@ use crate::overwatch::Services;
use crate::services::ServiceData; use crate::services::ServiceData;
use tokio::runtime::Handle; use tokio::runtime::Handle;
use tokio::sync::mpsc::Sender; use tokio::sync::mpsc::Sender;
use tracing::{error, info};
#[cfg(feature = "instrumentation")] #[cfg(feature = "instrumentation")]
use tracing::instrument; use tracing::instrument;
use tracing::{error, info};
// internal // internal
use crate::services::relay::Relay; use crate::services::relay::Relay;

2
overwatch-rs/src/overwatch/mod.rs
View File

@ -15,9 +15,9 @@ use tokio::runtime::{Handle, Runtime};
use tokio::sync::mpsc::Receiver; use tokio::sync::mpsc::Receiver;
use tokio::sync::oneshot; use tokio::sync::oneshot;
use tokio::task::JoinHandle; use tokio::task::JoinHandle;
use tracing::{error, info};
#[cfg(feature = "instrumentation")] #[cfg(feature = "instrumentation")]
use tracing::instrument; use tracing::instrument;
use tracing::{error, info};
// internal // internal
use crate::overwatch::commands::{ use crate::overwatch::commands::{

3
overwatch-rs/src/services/relay.rs
View File

@ -181,8 +181,7 @@ impl<S: ServiceData> Relay<S> {
self.overwatch_handle.send(relay_command).await; self.overwatch_handle.send(relay_command).await;
} }
#[cfg_attr(feature = "instrumentation", instrument(skip_all, err(Debug))) #[cfg_attr(feature = "instrumentation", instrument(skip_all, err(Debug)))]
]
async fn handle_relay_response( async fn handle_relay_response(
&self, &self,
receiver: oneshot::Receiver<RelayResult>, receiver: oneshot::Receiver<RelayResult>,