zakura-tower-batch-control 1.1.0

Tower middleware for batch request processing. Internal Zakura fork, published to support cargo install zakura
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

//! Batch message types.

use tokio::sync::{oneshot, OwnedSemaphorePermit};

use super::error::ServiceError;

/// Message sent to the batch worker.
#[derive(Debug)]
pub(crate) enum Message<Request, Fut> {
    /// A batch item request.
    Item {
        request: Request,
        tx: Tx<Fut>,
        span: tracing::Span,
        _permit: OwnedSemaphorePermit,
    },

    /// An explicit request to flush the pending batch.
    Flush {
        span: tracing::Span,
        _permit: OwnedSemaphorePermit,
    },
}

/// Response sender
pub(crate) type Tx<Fut> = oneshot::Sender<Result<Fut, ServiceError>>;

/// Response receiver
pub(crate) type Rx<Fut> = oneshot::Receiver<Result<Fut, ServiceError>>;