attributes: permit setting parent span via #[instrument(parent = …)] (#2091)

This PR extends the `#[instrument]` attribute to accept an optionally
`parent = …` argument that provides an explicit parent to the generated
`Span`.

## Motivation

This PR resolves #2021 and partially resolves #879. (It only partly
resolves #879 in that it only provides a mechanism for specifying an
explicit parent, but *not* for invoking `follows_from`.)

## Solution

This PR follows the implementation strategy articulated by @hawkw:
https://github.com/tokio-rs/tracing/issues/879#issuecomment-668168468.
The user-provided value to the `parent` argument may be any expression,
and this expression is provided directly to the invocation of
[`span!`](https://tracing.rs/tracing/macro.span.html).
This commit is contained in:
Jack Wrenn 2022-04-25 17:54:17 -04:00 committed by Eliza Weisman
parent 0d13e5b419
commit 4c0e30fb32
4 changed files with 153 additions and 0 deletions

View File

@ -11,6 +11,7 @@ pub(crate) struct InstrumentArgs {
level: Option<Level>,
pub(crate) name: Option<LitStr>,
target: Option<LitStr>,
pub(crate) parent: Option<Expr>,
pub(crate) skips: HashSet<Ident>,
pub(crate) skip_all: bool,
pub(crate) fields: Option<Fields>,
@ -123,6 +124,12 @@ impl Parse for InstrumentArgs {
}
let target = input.parse::<StrArg<kw::target>>()?.value;
args.target = Some(target);
} else if lookahead.peek(kw::parent) {
if args.target.is_some() {
return Err(input.error("expected only a single `parent` argument"));
}
let parent = input.parse::<ExprArg<kw::parent>>()?;
args.parent = Some(parent.value);
} else if lookahead.peek(kw::level) {
if args.level.is_some() {
return Err(input.error("expected only a single `level` argument"));
@ -193,6 +200,23 @@ impl<T: Parse> Parse for StrArg<T> {
}
}
struct ExprArg<T> {
value: Expr,
_p: std::marker::PhantomData<T>,
}
impl<T: Parse> Parse for ExprArg<T> {
fn parse(input: ParseStream<'_>) -> syn::Result<Self> {
let _ = input.parse::<T>()?;
let _ = input.parse::<Token![=]>()?;
let value = input.parse()?;
Ok(Self {
value,
_p: std::marker::PhantomData,
})
}
}
struct Skips(HashSet<Ident>);
impl Parse for Skips {
@ -374,6 +398,7 @@ mod kw {
syn::custom_keyword!(skip_all);
syn::custom_keyword!(level);
syn::custom_keyword!(target);
syn::custom_keyword!(parent);
syn::custom_keyword!(name);
syn::custom_keyword!(err);
syn::custom_keyword!(ret);

View File

@ -135,6 +135,8 @@ fn gen_block<B: ToTokens>(
let target = args.target();
let parent = args.parent.iter();
// filter out skipped fields
let quoted_fields: Vec<_> = param_names
.iter()
@ -182,6 +184,7 @@ fn gen_block<B: ToTokens>(
quote!(tracing::span!(
target: #target,
#(parent: #parent,)*
#level,
#span_name,
#(#quoted_fields,)*

View File

@ -345,6 +345,29 @@ mod expand;
/// // ...
/// }
/// ```
/// Overriding the generated span's parent:
/// ```
/// # use tracing_attributes::instrument;
/// #[instrument(parent = None)]
/// pub fn my_function() {
/// // ...
/// }
/// ```
/// ```
/// # use tracing_attributes::instrument;
/// // A struct which owns a span handle.
/// struct MyStruct
/// {
/// span: tracing::Span
/// }
///
/// impl MyStruct
/// {
/// // Use the struct's `span` field as the parent span
/// #[instrument(parent = &self.span, skip(self))]
/// fn my_method(&self) {}
/// }
/// ```
///
/// To skip recording an argument, pass the argument's name to the `skip`:
///

View File

@ -0,0 +1,102 @@
use tracing::{subscriber::with_default, Id, Level};
use tracing_attributes::instrument;
use tracing_mock::*;
#[instrument]
fn with_default_parent() {}
#[instrument(parent = parent_span, skip(parent_span))]
fn with_explicit_parent<P>(parent_span: P)
where
P: Into<Option<Id>>,
{
}
#[test]
fn default_parent_test() {
let contextual_parent = span::mock().named("contextual_parent");
let child = span::mock().named("with_default_parent");
let (subscriber, handle) = subscriber::mock()
.new_span(
contextual_parent
.clone()
.with_contextual_parent(None)
.with_explicit_parent(None),
)
.new_span(
child
.clone()
.with_contextual_parent(Some("contextual_parent"))
.with_explicit_parent(None),
)
.enter(child.clone())
.exit(child.clone())
.enter(contextual_parent.clone())
.new_span(
child
.clone()
.with_contextual_parent(Some("contextual_parent"))
.with_explicit_parent(None),
)
.enter(child.clone())
.exit(child)
.exit(contextual_parent)
.done()
.run_with_handle();
with_default(subscriber, || {
let contextual_parent = tracing::span!(Level::TRACE, "contextual_parent");
with_default_parent();
contextual_parent.in_scope(|| {
with_default_parent();
});
});
handle.assert_finished();
}
#[test]
fn explicit_parent_test() {
let contextual_parent = span::mock().named("contextual_parent");
let explicit_parent = span::mock().named("explicit_parent");
let child = span::mock().named("with_explicit_parent");
let (subscriber, handle) = subscriber::mock()
.new_span(
contextual_parent
.clone()
.with_contextual_parent(None)
.with_explicit_parent(None),
)
.new_span(
explicit_parent
.with_contextual_parent(None)
.with_explicit_parent(None),
)
.enter(contextual_parent.clone())
.new_span(
child
.clone()
.with_contextual_parent(Some("contextual_parent"))
.with_explicit_parent(Some("explicit_parent")),
)
.enter(child.clone())
.exit(child)
.exit(contextual_parent)
.done()
.run_with_handle();
with_default(subscriber, || {
let contextual_parent = tracing::span!(Level::INFO, "contextual_parent");
let explicit_parent = tracing::span!(Level::INFO, "explicit_parent");
contextual_parent.in_scope(|| {
with_explicit_parent(&explicit_parent);
});
});
handle.assert_finished();
}