Struct Lock 

pub struct Lock<L: LockLayout = DefaultLockLayout> { /* private fields */ }

Fleet-shared lock handle. Clones share one event cursor.

Implementations

impl Lock<DefaultLockLayout>

pub fn new(fleet: Arc<Fleet>) -> Result<Self>

Subscribe after all currently committed transition events.

pub fn replay_retained(fleet: Arc<Fleet>) -> Result<Self>

Replay retained transitions. Intended for tests and diagnostics.

impl<L: LockLayout> Lock<L>

pub fn with_layout(fleet: Arc<Fleet>) -> Result<Self>

Subscribe with a custom storage layout.

pub fn replay_layout(fleet: Arc<Fleet>) -> Result<Self>

Replay retained transitions with a custom storage layout. Intended for tests and diagnostics.

pub fn try_acquire( &self, key: &LockKey, owner: &LockOwner, ttl: Duration, ) -> Result<LockAcquire>

pub fn renew( &self, lease: &LockLease, ttl: Duration, ) -> Result<Option<LockLease>>

Renew only if this exact tenure is still current.

pub fn renew_owned( &self, key: &LockKey, owner: &LockOwner, ttl: Duration, ) -> Result<Option<LockLease>>

Renew by a caller-retained owner identity.

pub fn release(&self, lease: &LockLease) -> Result<bool>

Release only if this exact tenure is still current.

pub fn release_owned(&self, key: &LockKey, owner: &LockOwner) -> Result<bool>

Release only when the current owner bytes match.

pub fn force_release(&self, key: &LockKey) -> Result<bool>

Release the current tenure without checking its owner.

This is the explicit administrative escape hatch required by lock providers such as Laravel’s forceRelease. Normal callers should use Self::release or Self::release_owned.

pub fn current(&self, key: &LockKey) -> Result<Option<LockLease>>

Read authoritative current state for one key.

pub fn restore( &self, key: &LockKey, owner: &LockOwner, ) -> Result<Option<LockLease>>

Restore the current tenure only when its owner bytes match.

pub fn poll(&self) -> LockPoll

Drain every currently visible transition from all writer lanes.

pub fn reset_transport(&self) -> Result<()>

Clear lock state and transition history during quiescent owner boot.

pub fn unlink(&self) -> Result<()>

Remove the state and event SHM objects.

pub fn event_fd(&self) -> Result<RingEventFd>

Create this process’ readiness fd for lock transitions.

Trait Implementations

impl<L: Clone + LockLayout> Clone for Lock<L>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.