Struct LroRecorder 

#[non_exhaustive]
pub struct LroRecorder { /* private fields */ }

A recorder that manages LRO spans and propagates active telemetry context.

To prevent concurrent mutation race conditions under multi-threaded tokio executors, LroRecorder is largely immutable. Context updates (like setting the transient attempt_count during a polling cycle) are performed using copy-on-write builders (with_attempt_count) to establish new task-local scopes.

The destination_id is an exception: it is a write-once, read-many value shared across all clones of a given recorder, ensuring that once discovered, the ID propagates to all future polling spans.

Implementations

impl LroRecorder

pub fn new(span: Span) -> Self

Creates a new LroRecorder wrapping the given tracing Span.

pub fn current() -> Option<Self>

Returns the recorder in the current task scope.

pub async fn scope<F, T>(&self, future: F) -> T

where F: Future<Output = T>,

Runs a future within the scope of this recorder.

pub fn span(&self) -> &Span

Returns the active LRO tracing Span wrapped by this recorder.

pub fn attempt_count(&self) -> Option<u32>

Returns the current LRO polling attempt count, if active.

This returns Some(u32) when queried during an active polling attempt, and None otherwise (e.g., when executing outside the scope of an active polling cycle).

impl LroRecorder

pub fn with_attempt_count(&self, count: u32) -> Self

Creates a new clone of LroRecorder carrying the specified LRO polling attempt count.

Since LroRecorder is immutable to guarantee thread-safety, this updates the context via copy-on-write, returning a new value to be bound to a new task-local scope.

pub fn record_destination_id(&self, name: &str)

pub fn destination_id(&self) -> Option<String>

pub fn record_error(&self, err: &Error)

pub async fn record_action<F, Fut, T>(&self, f: F) -> T

where F: FnOnce(Span) -> Fut, Fut: Future<Output = T>,

Trait Implementations

impl Clone for LroRecorder

fn clone(&self) -> LroRecorder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LroRecorder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.