pg_ 0.1.0

pg_
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::fmt::Display;

pub fn heartbeat<R: AsRef<str>, E: Display, F: Send + Future<Output = Result<R, E>> + 'static>(
  kind: impl Into<String> + Send + 'static,
  name: impl Into<String> + Send + 'static,
  fut: F,
) {
  tokio::spawn(async move {
    let kind = kind.into();
    let name = name.into();
    match fut.await {
      Ok(msg) => {
        let msg = msg.as_ref();
        if !msg.is_empty() {
          tracing::info!("{kind} {name} {msg}");
        }
      }
      Err(e) => {
        tracing::error!("{kind} {name} {e}")
      }
    }
  });
}