Struct LockManager 

pub struct LockManager { /* private fields */ }

Lock manager for stripe locking during preflight phase

Provides per-key locking with configurable number of stripes. Non-conflicting keys map to different stripes and can be locked concurrently.

Implementations

impl LockManager

pub fn new(num_stripes: usize) -> Self

Create a new lock manager with the specified number of stripes

Common values: 256, 512, 1024 More stripes = less contention but more memory

pub fn read_lock(&self, key: &[u8]) -> RwLockReadGuard<'_, ()>

Acquire read lock for a key (blocking)

Multiple readers can hold locks on the same stripe concurrently. Used during preflight when reading state.

This method blocks until the lock is acquired.

pub fn write_lock(&self, key: &[u8]) -> RwLockWriteGuard<'_, ()>

Acquire write lock for a key (blocking)

Only one writer can hold a lock on a stripe at a time. Used during preflight when validating writes.

This method blocks until the lock is acquired.

pub fn num_stripes(&self) -> usize

Get the number of stripes