1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

#![feature(impl_trait_in_assoc_type)]
#![doc(
    html_logo_url = "https://github.com/cloudwego/volo/raw/main/.github/assets/logo.png?sanitize=true"
)]
#![cfg_attr(not(doctest), doc = include_str!("../README.md"))]

pub use async_trait::async_trait;
pub use motore::{layer, layer::Layer, service, Service};
pub use tokio::main;

pub mod context;
pub mod discovery;
pub mod loadbalance;
pub mod net;
pub mod util;
pub use hack::Unwrap;

pub mod client;
mod hack;
mod macros;

pub use faststr::FastStr;
pub use metainfo::METAINFO;

/// volo::spawn will spawn a task and derive the metainfo
pub fn spawn<T>(future: T) -> tokio::task::JoinHandle<T::Output>
where
    T: futures::Future + Send + 'static,
    T::Output: Send + 'static,
{
    let mi = METAINFO
        .try_with(|m| {
            let prev_mi = m.take();
            let (m1, m2) = prev_mi.derive();
            m.replace(m1);
            m2
        })
        .unwrap_or_else(|_| metainfo::MetaInfo::new());

    tokio::spawn(METAINFO.scope(std::cell::RefCell::new(mi), future))
}