Crate datafusion_common_runtime 

Re-exports

pub use common::SpawnedTask;

Modules

common

Structs

JoinSet

A wrapper around Tokio’s JoinSet that forwards all API calls while optionally instrumenting spawned tasks and blocking closures with custom tracing behavior. If no tracer is injected via set_join_set_tracer, tasks and closures are executed without any instrumentation.

Enums

JoinSetTracerError

A custom error type for tracer injection failures.

Traits

JoinSetTracer

A trait for injecting instrumentation into either asynchronous futures or blocking closures at runtime.

Functions

set_join_set_tracer

Set the custom tracer for both futures and blocking closures.

trace_block

Optionally instruments a blocking closure with custom tracing.

trace_future

Optionally instruments a future with custom tracing.