Struct SamplingCoordinator 

pub struct SamplingCoordinator { /* private fields */ }

Wrapper around a SamplingClient that coalesces concurrent create_message calls into batched create_message calls (within a configurable time window OR batch-size limit).

Construct via SamplingCoordinator::new or SamplingCoordinator::with_settings. Drop the coordinator’s last Arc clone to shut down the worker task.

Thread safety: cheap to clone; every clone shares the same underlying mpsc + worker task. Concurrent callers are serialised by the worker.

Implementations

impl SamplingCoordinator

pub fn new(inner: Arc<dyn SamplingClient>) -> Arc<Self>

Build a coordinator wrapping the supplied SamplingClient with default settings (5s window, max-batch 10).

pub fn with_settings( inner: Arc<dyn SamplingClient>, window: Duration, max_batch: usize, ) -> Arc<Self>

Build a coordinator with explicit settings. window is the upper bound the worker waits before flushing a non-empty buffer; max_batch is the buffer size that triggers an immediate flush regardless of window.

pub async fn submit( &self, params: CreateMessageRequestParams, ) -> Result<CreateMessageResult, SamplingError>

Coalesced equivalent of SamplingClient::create_message. The returned future resolves when the worker has demultiplexed the coalesced batch’s response back to this submission’s slot.

pub async fn shutdown(self: Arc<Self>)

Drain the worker task. Called rarely in tests; production drops the coordinator on daemon shutdown.

Trait Implementations

impl SamplingClient for SamplingCoordinator

fn create_message<'life0, 'async_trait>( &'life0 self, params: CreateMessageRequestParams, ) -> Pin<Box<dyn Future<Output = Result<CreateMessageResult, SamplingError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,