Struct CorrelationTracker 

pub struct CorrelationTracker { /* private fields */ }

Tracker for managing correlation contexts across operations

Implementations

impl CorrelationTracker

pub fn new() -> Self

Create a new correlation tracker

pub fn register(&self, correlation_id: CorrelationId)

Register a new correlation ID

pub async fn store_context(&self, context: CorrelationContext)

Store a correlation context

pub async fn get_context( &self, correlation_id: &CorrelationId, ) -> Option<CorrelationContext>

Retrieve a correlation context

pub async fn remove_context( &self, correlation_id: &CorrelationId, ) -> Option<CorrelationContext>

Remove a correlation context

pub async fn get_active_contexts(&self) -> Vec<CorrelationContext>

Get all active correlation contexts

pub async fn cleanup_old_contexts(&self, max_age: Duration)

Clean up old contexts (should be called periodically)

Trait Implementations

impl Debug for CorrelationTracker

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

Formats the value using the given formatter.

impl Default for CorrelationTracker

fn default() -> Self

Returns the “default value” for a type.