Struct SemaphorePermits 

pub struct SemaphorePermits { /* private fields */ }

Semaphore-based backpressure implementation.

Enforces a maximum number of bytes that can be buffered at once. When the limit is reached, acquire() suspends on the executor until enough capacity is released, then resumes in FIFO order. Acquires all N bytes in a single atomic operation (O(1), not O(N)).

Example

use monocoque_core::backpressure::{BytePermits, SemaphorePermits};

// Allow up to 10MB of buffered data
let permits = SemaphorePermits::new(10 * 1024 * 1024);

// Acquire permit for 1KB write
let permit = permits.acquire(1024).await;
// ... perform write ...
drop(permit); // releases 1024 bytes back to the pool

Implementations

impl SemaphorePermits

pub fn new(max_bytes: usize) -> Self

Create a new semaphore-based backpressure controller.

Arguments

• max_bytes - Maximum number of bytes that can be buffered

Trait Implementations

impl BytePermits for SemaphorePermits

async fn acquire(&self, n_bytes: usize) -> Permit

Acquire permission to write n_bytes.

impl Clone for SemaphorePermits

fn clone(&self) -> SemaphorePermits

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.