com.github.cloudyrock.mongock.driver.core.lock

Interface LockRepository<ENTITY_CLASS>

All Superinterfaces:

Process, Repository<LockEntry,ENTITY_CLASS>

public interface LockRepository<ENTITY_CLASS>
extends Repository<LockEntry,ENTITY_CLASS>

Repository interface to manage lock in database, which will be used by LockManager

Method Summary

Modifier and Type	Method and Description
void	deleteAll()
LockEntry	findByKey(String lockKey) Retrieves a lock by key
void	insertUpdate(LockEntry newLock) a) If there is an existing lock in the database for the same key and owner(existingLock.key==newLock.key && existingLoc.owner==newLock.owner), then the lock in database is updated/refreshed with the new values.
void	removeByKeyAndOwner(String lockKey, String owner) Removes from database all the locks with the same key(only can be one) and owner
void	updateIfSameOwner(LockEntry newLock) The only goal of this method is to update(mainly to extend the expiry date) the lock in case is already owned.

Methods inherited from interface com.github.cloudyrock.mongock.driver.core.common.Repository

mapFieldInstances, toEntity

Methods inherited from interface com.github.cloudyrock.mongock.utils.Process

initialize

Method Detail

insertUpdate

void insertUpdate(LockEntry newLock)
           throws LockPersistenceException

a) If there is an existing lock in the database for the same key and owner(existingLock.key==newLock.key && existingLoc.owner==newLock.owner), then the lock in database is updated/refreshed with the new values. The most common scenario is to extend the lock's expiry date. b) If there is a existing lock in the database for the same key and different owner, but expired(existingLock.key==newLock.key && existingLoc.owner!=newLock.owner && expiresAt > now), the lock is replaced with the newLock, so the owner of the lock for that key is newLock.owner c) If scenario b, but lock is not expired yet, should throw an LockPersistenceException. d) If there isn't any lock with key=newLock.key, newLock is inserted.

Parameters:

newLock - lock to replace the existing one or be inserted.

Throws:

LockPersistenceException - if there is a lock in database with same key, but is expired and belong to another owner or cannot insert/update the lock for any other reason

updateIfSameOwner

void updateIfSameOwner(LockEntry newLock)
                throws LockPersistenceException

The only goal of this method is to update(mainly to extend the expiry date) the lock in case is already owned. So it requires a Lock for the same key and owner(existingLock.key==newLock.key && existingLoc.owner==newLock.owner). If there is no lock for the key or it doesn't belong to newLock.owner, a LockPersistenceException is thrown.

Parameters:

newLock - lock to replace the existing one or be inserted.

Throws:

LockPersistenceException - if there is a lock in database with same key, but is expired and belong to another owner or cannot insert/update the lock for any other reason

findByKey

LockEntry findByKey(String lockKey)

Retrieves a lock by key

Parameters:

lockKey - key

Returns:

LockEntry

removeByKeyAndOwner

void removeByKeyAndOwner(String lockKey,
                         String owner)

Removes from database all the locks with the same key(only can be one) and owner

Parameters:

lockKey - lock key

owner - lock owner

deleteAll

void deleteAll()