Struct RequestBatcher 

pub struct RequestBatcher { /* private fields */ }

Request batcher for a module.

Implementations

impl RequestBatcher

pub fn new(module_name: String, config: BatchConfig) -> Self

Creates a new request batcher.

pub async fn queue(&self, request: BatchedRequest) -> Result<(), String>

Queues a request for batching.

pub async fn flush(&self)

Flushes pending requests into a batch.

pub fn take_receiver(&self) -> Option<Receiver<RequestBatch>>

Returns the batch receiver for consumption.

pub fn stats(&self) -> BatchStats

Returns statistics.

Trait Implementations

impl Debug for RequestBatcher

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

Formats the value using the given formatter.