Struct EntityLockManager 

pub struct EntityLockManager { /* private fields */ }

Advisory entity lock manager for a single session.

Implementations

impl EntityLockManager

pub fn new(pool: DbPool, session_id: impl Into<String>) -> Self

pub async fn try_acquire(&self, entity_name: &str) -> Result<bool, MemoryError>

Try to acquire an advisory lock on entity_name.

• If no lock exists: INSERT and return true.
• If the current session already holds the lock: UPDATE expires_at, return true.
• If another session holds a non-expired lock: retry with exponential backoff.
• After MAX_RETRIES failures: return false (caller proceeds without lock).

Expired locks (past expires_at) are atomically reclaimed on the INSERT conflict.

Errors

Returns an error on database failures.

pub async fn extend_lock( &self, entity_name: &str, extra_secs: i64, ) -> Result<bool, MemoryError>

Extend the TTL of a lock held by this session.

Called before long operations (e.g., an LLM call inside entity resolution) to prevent the lock from expiring while work is in progress.

Returns true if the lock was extended (still held by this session).

Errors

Returns an error on database failures.

pub async fn release(&self, entity_name: &str) -> Result<(), MemoryError>

Release the lock on entity_name held by this session.

No-op if the lock was already reclaimed by another session.

Errors

Returns an error on database failures.

pub async fn release_all(&self) -> Result<(), MemoryError>

Release all locks held by this session.

Called on agent shutdown to avoid leaving locks until TTL expiry.

Errors

Returns an error on database failures.