Struct FixedSizeSlotSupplier 

pub struct FixedSizeSlotSupplier<SK> { /* private fields */ }

Implements SlotSupplier with a fixed number of slots

Implementations

impl<SK> FixedSizeSlotSupplier<SK>

pub fn new(size: usize) -> FixedSizeSlotSupplier<SK>

Create a slot supplier which will only hand out at most the provided number of slots

Trait Implementations

impl<SK> SlotSupplier for FixedSizeSlotSupplier<SK>

where SK: SlotKind + Send + Sync,

type SlotKind = SK

The kind of slot this supplier is supplying.

fn reserve_slot<'life0, 'life1, 'async_trait>( &'life0 self, _: &'life1 dyn SlotReservationContext, ) -> Pin<Box<dyn Future<Output = SlotSupplierPermit> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FixedSizeSlotSupplier<SK>: 'async_trait,

Block until a slot is available, then return a permit for the slot.

fn try_reserve_slot( &self, _: &dyn SlotReservationContext, ) -> Option<SlotSupplierPermit>

Try to immediately reserve a slot, returning None if one is not available. Implementations must not block, or risk blocking the async event loop.

fn mark_slot_used( &self, _ctx: &dyn SlotMarkUsedContext<SlotKind = <FixedSizeSlotSupplier<SK> as SlotSupplier>::SlotKind>, )

Marks a slot as actually now being used. This is separate from reserving one because the pollers need to reserve a slot before they have actually obtained work from server. Once that task is obtained (and validated) then the slot can actually be used to work on the task.

fn release_slot( &self, _ctx: &dyn SlotReleaseContext<SlotKind = <FixedSizeSlotSupplier<SK> as SlotSupplier>::SlotKind>, )

Frees a slot.

fn available_slots(&self) -> Option<usize>

If this implementation knows how many slots are available at any moment, it should return that here.

fn slot_supplier_kind(&self) -> String

Returns a human-friendly identifier describing this supplier implementation for diagnostics and telemetry.