Struct FastraceLayer 

#[non_exhaustive]
pub struct FastraceLayer {}

Available on crate feature layers-fastrace only.

Add fastrace for every operation.

Examples

Basic Setup

let _ = Operator::new(services::Memory::default())?
    .layer(FastraceLayer::new())
    .finish();

Real usage

let reporter = fastrace_jaeger::JaegerReporter::new("127.0.0.1:6831".parse()?, "opendal").unwrap();
fastrace::set_reporter(reporter, fastrace::collector::Config::default());

{
    let root = Span::root("op", SpanContext::random());
    let runtime = tokio::runtime::Runtime::new()?;
    runtime.block_on(
        async {
            let _ = dotenvy::dotenv();
            let op = Operator::new(services::Memory::default())?
                .layer(FastraceLayer::new())
                .finish();
            op.write("test", "0".repeat(16 * 1024 * 1024).into_bytes())
                .await?;
            op.stat("test").await?;
            op.read("test").await?;
            Ok::<(), opendal_core::Error>(())
        }
        .in_span(Span::enter_with_parent("test", &root)),
    )?;
}

fastrace::flush();

Output

OpenDAL is using fastrace for tracing internally.

To enable fastrace output, please init one of the reporter that fastrace supports.

For example:

let reporter = fastrace_jaeger::JaegerReporter::new("127.0.0.1:6831".parse()?, "opendal").unwrap();
fastrace::set_reporter(reporter, fastrace::collector::Config::default());

For real-world usage, please take a look at fastrace-datadog or fastrace-jaeger .

Implementations

impl FastraceLayer

pub fn new() -> FastraceLayer

Create a new FastraceLayer.

Trait Implementations

impl Clone for FastraceLayer

fn clone(&self) -> FastraceLayer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for FastraceLayer

fn default() -> FastraceLayer

Returns the “default value” for a type.

impl<A> Layer<A> for FastraceLayer

where A: Access,

type LayeredAccess = FastraceAccessor<A>

The layered accessor that returned by this layer.

fn layer(&self, inner: A) -> <FastraceLayer as Layer<A>>::LayeredAccess

Intercept the operations on the underlying storage.