Struct ReplayRecorder 

pub struct ReplayRecorder { /* private fields */ }

Stateful recorder that accumulates extension runtime events during a dispatch cycle and produces a deterministic ReplayTraceBundle.

Events are pushed in arrival order; the recorder’s finish method canonicalizes ordering, applies the budget gate, and builds the diagnostic snapshot.

Implementations

impl ReplayRecorder

pub fn new(trace_id: impl Into<String>, config: ReplayLaneConfig) -> Self

Create a new recorder for a single dispatch cycle.

pub const fn logical_clock(&self) -> u64

Current logical clock value.

pub const fn event_count(&self) -> u64

Number of events recorded so far.

pub const fn tick(&mut self) -> u64

Advance the logical clock and return the new value.

pub fn record( &mut self, extension_id: impl Into<String>, request_id: impl Into<String>, kind: ReplayEventKind, attributes: BTreeMap<String, String>, )

Record an event at the current logical clock.

pub fn record_scheduled( &mut self, extension_id: impl Into<String>, request_id: impl Into<String>, attributes: BTreeMap<String, String>, )

Record a Scheduled event.

pub fn record_queue_accepted( &mut self, extension_id: impl Into<String>, request_id: impl Into<String>, attributes: BTreeMap<String, String>, )

Record a QueueAccepted event.

pub fn record_policy_decision( &mut self, extension_id: impl Into<String>, request_id: impl Into<String>, attributes: BTreeMap<String, String>, )

Record a PolicyDecision event.

pub fn record_cancelled( &mut self, extension_id: impl Into<String>, request_id: impl Into<String>, attributes: BTreeMap<String, String>, )

Record a Cancelled event.

pub fn record_retried( &mut self, extension_id: impl Into<String>, request_id: impl Into<String>, attributes: BTreeMap<String, String>, )

Record a Retried event.

pub fn record_completed( &mut self, extension_id: impl Into<String>, request_id: impl Into<String>, attributes: BTreeMap<String, String>, )

Record a Completed event.

pub fn record_failed( &mut self, extension_id: impl Into<String>, request_id: impl Into<String>, attributes: BTreeMap<String, String>, )

Record a Failed event.

pub fn finish( self, observation: ReplayCaptureObservation, ) -> Result<ReplayLaneResult, ReplayTraceValidationError>

Finalize the recording: canonicalize event ordering, apply budget gate, and build the diagnostic snapshot.

The observation provides runtime telemetry needed for budget gating.

Errors

Returns an error if the trace bundle fails validation.

pub fn finish_and_compare( self, observation: ReplayCaptureObservation, reference: &ReplayTraceBundle, ) -> Result<(ReplayLaneResult, ReplayComparisonResult), ReplayTraceValidationError>

Finalize and compare against a reference bundle.

Returns the lane result together with a comparison result that includes the first divergence (if any) and derived root-cause hints.

Errors

Returns an error if either bundle fails validation.

Trait Implementations

impl Debug for ReplayRecorder

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

Formats the value using the given formatter.