Struct RelayManager 

pub struct RelayManager { /* private fields */ }

Manages circuit relay v2 reservations.

All public methods are safe to call from multiple threads concurrently; the internal RwLock is a parking_lot lock and never blocks async tasks for long.

Implementations

impl RelayManager

pub fn new(max_reservations: usize) -> Self

Create a new manager with the given capacity limit.

pub fn add_reservation( &self, reservation: RelayReservation, ) -> Result<(), RelayError>

Insert a new reservation.

Fails with:

• RelayError::AlreadyExists if reservation.relay_peer_id is already tracked.
• RelayError::AtCapacity if the cap would be exceeded.

pub fn remove_reservation(&self, relay_peer_id: &str) -> bool

Remove the reservation for relay_peer_id.

Returns true if a reservation existed and was removed.

pub fn get_reservation(&self, relay_peer_id: &str) -> Option<RelayReservation>

Look up a reservation by relay peer ID (cloned snapshot).

pub fn active_reservations(&self, now_ms: u64) -> Vec<RelayReservation>

Return all non-expired reservations as of now_ms.

pub fn expired_reservations(&self, now_ms: u64) -> Vec<String>

Return the peer IDs of all expired reservations.

pub fn prune_expired(&self, now_ms: u64) -> usize

Remove every expired reservation and return the count of removed entries.

pub fn reservation_count(&self) -> usize

Total number of tracked reservations (active + expired).

pub fn is_at_capacity(&self) -> bool

Returns true when the manager cannot accept any more reservations.