pub struct Registry { /* private fields */ }
Expand description
A shared, reusable store for spans.
A Registry
is a Subscriber
around which multiple Layer
s
implementing various behaviors may be added. Unlike other types
implementing Subscriber
, Registry
does not actually record traces itself:
instead, it collects and stores span data that is exposed to any Layer
s
wrapping it through implementations of the LookupSpan
trait.
The Registry
is responsible for storing span metadata, recording
relationships between spans, and tracking which spans are active and which
are closed. In addition, it provides a mechanism for Layer
s to store
user-defined per-span data, called extensions, in the registry. This
allows Layer
-specific data to benefit from the Registry
’s
high-performance concurrent storage.
This registry is implemented using a lock-free sharded slab, and is highly optimized for concurrent access.
Span ID Generation
Span IDs are not globally unique, but the registry ensures that no two currently active spans have the same ID within a process.
One of the primary responsibilities of the registry is to generate span
IDs. Therefore, it’s important for other code that interacts with the
registry, such as Layer
s, to understand the guarantees of the
span IDs that are generated.
The registry’s span IDs are guaranteed to be unique at a given point in time. This means that an active span will never be assigned the same ID as another currently active span. However, the registry will eventually reuse the IDs of closed spans, although an ID will never be reassigned immediately after a span has closed.
Spans are not considered closed by the Registry
until every
Span
reference with that ID has been dropped.
Thus: span IDs generated by the registry should be considered unique only at a given point in time, and only relative to other spans generated by the same process. Two spans with the same ID will not exist in the same process concurrently. However, if historical span data is being stored, the same ID may occur for multiple spans times in that data. If spans must be uniquely identified in historical data, the user code storing this data must assign its own unique identifiers to those spans. A counter is generally sufficient for this.
Similarly, span IDs generated by the registry are not unique outside of
a given process. Distributed tracing systems may require identifiers
that are unique across multiple processes on multiple machines (for
example, OpenTelemetry’s SpanId
s and TraceId
s). tracing
span
IDs generated by the registry should not be used for this purpose.
Instead, code which integrates with a distributed tracing system should
generate and propagate its own IDs according to the rules specified by
the distributed tracing system. These IDs can be associated with
tracing
spans using fields and/or stored span data.
Trait Implementations§
source§impl<'a> LookupSpan<'a> for Registry
impl<'a> LookupSpan<'a> for Registry
source§impl Subscriber for Registry
impl Subscriber for Registry
source§fn record(&self, _: &Id, _: &Record<'_>)
fn record(&self, _: &Id, _: &Record<'_>)
This is intentionally not implemented, as recording fields on a span is the responsibility of layers atop of this registry.
source§fn event(&self, _: &Event<'_>)
fn event(&self, _: &Event<'_>)
This is intentionally not implemented, as recording events is the responsibility of layers atop of this registry.
source§fn try_close(&self, id: Id) -> bool
fn try_close(&self, id: Id) -> bool
Decrements the reference count of the span with the given id
, and
removes the span if it is zero.
The allocated span slot will be reused when a new span is created.
source§fn register_callsite(&self, _: &'static Metadata<'static>) -> Interest
fn register_callsite(&self, _: &'static Metadata<'static>) -> Interest
source§fn new_span(&self, attrs: &Attributes<'_>) -> Id
fn new_span(&self, attrs: &Attributes<'_>) -> Id
source§fn record_follows_from(&self, _span: &Id, _follows: &Id)
fn record_follows_from(&self, _span: &Id, _follows: &Id)
source§fn event_enabled(&self, _event: &Event<'_>) -> bool
fn event_enabled(&self, _event: &Event<'_>) -> bool
source§fn clone_span(&self, id: &Id) -> Id
fn clone_span(&self, id: &Id) -> Id
source§fn current_span(&self) -> Current
fn current_span(&self) -> Current
source§fn on_register_dispatch(&self, subscriber: &Dispatch)
fn on_register_dispatch(&self, subscriber: &Dispatch)
source§fn max_level_hint(&self) -> Option<LevelFilter>
fn max_level_hint(&self) -> Option<LevelFilter>
Subscriber
will
enable, or None
, if the subscriber does not implement level-based
filtering or chooses not to implement this method. Read moreAuto Trait Implementations§
impl RefUnwindSafe for Registry
impl Send for Registry
impl Sync for Registry
impl Unpin for Registry
impl !UnwindSafe for Registry
Blanket Implementations§
source§impl<T, U> AsBindGroupShaderType<U> for T
impl<T, U> AsBindGroupShaderType<U> for T
source§fn as_bind_group_shader_type(&self, _images: &RenderAssets<Image>) -> U
fn as_bind_group_shader_type(&self, _images: &RenderAssets<Image>) -> U
T
ShaderType
for self
. When used in AsBindGroup
derives, it is safe to assume that all images in self
exist.source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
source§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Box<dyn Trait>
(where Trait: Downcast
) to Box<dyn Any>
. Box<dyn Any>
can
then be further downcast
into Box<ConcreteType>
where ConcreteType
implements Trait
.source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Rc<Trait>
(where Trait: Downcast
) to Rc<Any>
. Rc<Any>
can then be
further downcast
into Rc<ConcreteType>
where ConcreteType
implements Trait
.source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &Any
’s vtable from &Trait
’s.source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &mut Any
’s vtable from &mut Trait
’s.source§impl<T> DowncastSync for T
impl<T> DowncastSync for T
source§impl<S> FromSample<S> for S
impl<S> FromSample<S> for S
fn from_sample_(s: S) -> S
source§impl<T> FromWorld for Twhere
T: Default,
impl<T> FromWorld for Twhere
T: Default,
source§fn from_world(_world: &mut World) -> T
fn from_world(_world: &mut World) -> T
Self
using data from the given World
.source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
source§impl<T> SubscriberInitExt for T
impl<T> SubscriberInitExt for T
source§fn set_default(self) -> DefaultGuard
fn set_default(self) -> DefaultGuard
self
as the default subscriber in the current scope, returning a
guard that will unset it when dropped. Read moresource§fn try_init(self) -> Result<(), TryInitError>
fn try_init(self) -> Result<(), TryInitError>
self
as the global default subscriber in the current
scope, returning an error if one is already set. Read moresource§fn init(self)
fn init(self)
self
as the global default subscriber in the current
scope, panicking if this fails. Read more