Struct tower_batch_control::layer::BatchLayer

pub struct BatchLayer<Request> {
    max_items_in_batch: usize,
    max_batches: Option<usize>,
    max_latency: Duration,
    _handles_requests: PhantomData<fn(_: Request)>,
}

Adds a layer performing batch processing of requests.

The default Tokio executor is used to run the given service, which means that this layer can only be used on the Tokio runtime.

See the module documentation for more details.

Fields

max_items_in_batch: usize

max_batches: Option<usize>

max_latency: Duration

_handles_requests: PhantomData<fn(_: Request)>

Implementations

impl<Request> BatchLayer<Request>

pub fn new( max_items_in_batch: usize, max_batches: impl Into<Option<usize>>, max_latency: Duration, ) -> Self

Creates a new BatchLayer.

The wrapper is responsible for telling the inner service when to flush a batch of requests. See Batch::new() for details.

Trait Implementations

impl<Request> Debug for BatchLayer<Request>

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

Formats the value using the given formatter.

impl<S, Request> Layer<S> for BatchLayer<Request>

where S: Service<BatchControl<Request>> + Send + 'static, S::Future: Send, S::Response: Send, S::Error: Into<Box<dyn Error + Send + Sync + 'static>> + Send + Sync, Request: Send + 'static,

type Service = Batch<S, Request>

The wrapped service

fn layer(&self, service: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.