Struct MySqlDistributedReaderWriterLock 

pub struct MySqlDistributedReaderWriterLock { /* private fields */ }

A MySQL-based distributed reader-writer lock.

Uses a database table to track reader-writer state and transactions to ensure atomic operations. This allows multiple readers to hold the lock simultaneously while ensuring writers get exclusive access.

The table schema is:

CREATE TABLE distributed_locks (
    lock_name VARCHAR(255) PRIMARY KEY,
    reader_count INT NOT NULL DEFAULT 0,
    writer_held TINYINT(1) NOT NULL DEFAULT 0,
    version INT NOT NULL DEFAULT 0,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
);

Trait Implementations

impl DistributedReaderWriterLock for MySqlDistributedReaderWriterLock

type ReadHandle = MySqlReadLockHandle

Handle type for read (shared) locks.

type WriteHandle = MySqlWriteLockHandle

Handle type for write (exclusive) locks.

fn name(&self) -> &str

Returns the unique name identifying this lock.

async fn acquire_read( &self, timeout: Option<Duration>, ) -> LockResult<Self::ReadHandle>

Acquires a read (shared) lock.

async fn try_acquire_read(&self) -> LockResult<Option<Self::ReadHandle>>

Attempts to acquire a read lock without waiting.

async fn acquire_write( &self, timeout: Option<Duration>, ) -> LockResult<Self::WriteHandle>

Acquires a write (exclusive) lock.

async fn try_acquire_write(&self) -> LockResult<Option<Self::WriteHandle>>

Attempts to acquire a write lock without waiting.