Package com.coditory.sherlock

Class RxDistributedLockMock

java.lang.Object
com.coditory.sherlock.RxDistributedLockMock
All Implemented Interfaces:
RxDistributedLock
public final class RxDistributedLockMock extends Object implements RxDistributedLock

  • Method Details

    • releasedInMemoryLock

      public static RxDistributedLockMock releasedInMemoryLock()

    • acquiredInMemoryLock

      public static RxDistributedLockMock acquiredInMemoryLock()

    • releasedInMemoryLock

      public static RxDistributedLockMock releasedInMemoryLock(String lockId)

    • acquiredInMemoryLock

      public static RxDistributedLockMock acquiredInMemoryLock(String lockId)

    • releasedReentrantInMemoryLock

      public static RxDistributedLockMock releasedReentrantInMemoryLock()

    • acquiredReentrantInMemoryLock

      public static RxDistributedLockMock acquiredReentrantInMemoryLock()

    • releasedReentrantInMemoryLock

      public static RxDistributedLockMock releasedReentrantInMemoryLock(String lockId)

    • acquiredReentrantInMemoryLock

      public static RxDistributedLockMock acquiredReentrantInMemoryLock(String lockId)

    • lockStub

      public static RxDistributedLockMock lockStub(boolean result)

    • lockStub

      public static RxDistributedLockMock lockStub(boolean acquireResult, boolean releaseResult)

    • lockStub

      public static RxDistributedLockMock lockStub(String lockId, boolean result)

    • lockStub

      public static RxDistributedLockMock lockStub(String lockId, boolean acquireResult, boolean releaseResult)

    • sequencedLock

      public static RxDistributedLockMock sequencedLock(List<Boolean> acquireResults, List<Boolean> releaseResults)

    • sequencedLock

      public static RxDistributedLockMock sequencedLock(String lockId, List<Boolean> acquireResults, List<Boolean> releaseResults)

    • getId

      public String getId()
      Description copied from interface: RxDistributedLock
      Return the lock id.
      Specified by:
      getId in interface RxDistributedLock
      Returns:
      the lock id

    • acquire

      public io.reactivex.Single<com.coditory.sherlock.connector.AcquireResult> acquire()
      Description copied from interface: RxDistributedLock
      Try to acquire the lock. Lock is acquired for a pre configured duration.
      Specified by:
      acquire in interface RxDistributedLock
      Returns:
      AcquireResult.SUCCESS if lock is acquired

    • acquire

      public io.reactivex.Single<com.coditory.sherlock.connector.AcquireResult> acquire(Duration duration)
      Description copied from interface: RxDistributedLock
      Try to acquire the lock for a given duration.
      Specified by:
      acquire in interface RxDistributedLock
      Parameters:
      duration - how much time must pass for the acquired lock to expire
      Returns:
      AcquireResult.SUCCESS if lock is acquired

    • acquireForever

      public io.reactivex.Single<com.coditory.sherlock.connector.AcquireResult> acquireForever()
      Description copied from interface: RxDistributedLock
      Try to acquire the lock without expiring date.

      It is potentially dangerous. Lookout for a situation when the lock owning instance goes down with out releasing the lock.

      Specified by:
      acquireForever in interface RxDistributedLock
      Returns:
      AcquireResult.SUCCESS if lock is acquired

    • release

      public io.reactivex.Single<com.coditory.sherlock.connector.ReleaseResult> release()
      Description copied from interface: RxDistributedLock
      Try to release the lock.
      Specified by:
      release in interface RxDistributedLock
      Returns:
      ReleaseResult.SUCCESS if lock was released by this method invocation. If lock has expired or was released earlier then ReleaseResult.FAILURE is returned.

    • successfulReleases

      public int successfulReleases()
      Returns:
      the count of successful releases

    • successfulAcquisitions

      public int successfulAcquisitions()
      Returns:
      the count of successful acquisitions

    • releases

      public int releases()
      Returns:
      the count of all releases (successful and unsuccessful)

    • acquisitions

      public int acquisitions()
      Returns:
      the count of all acquisitions (successful and unsuccessful)

    • rejectedReleases

      public int rejectedReleases()
      Returns:
      the count of rejected releases

    • rejectedAcquisitions

      public int rejectedAcquisitions()
      Returns:
      the count of rejected acquisitions

    • wasAcquired

      public boolean wasAcquired()
      Returns:
      true if lock was successfully acquired at least once

    • wasReleased

      public boolean wasReleased()
      Returns:
      true if lock was successfully released at least once

    • wasAcquiredAndReleased

      public boolean wasAcquiredAndReleased()
      Returns:
      true if lock was successfully acquired and released

    • wasAcquireRejected

      public boolean wasAcquireRejected()
      Returns:
      true if lock was acquired without success at least once

    • wasReleaseRejected

      public boolean wasReleaseRejected()
      Returns:
      true if lock was released without success at least once

    • wasAcquireInvoked

      public boolean wasAcquireInvoked()
      Returns:
      true if acquire operation was invoked at least once

    • wasReleaseInvoked

      public boolean wasReleaseInvoked()
      Returns:
      true if release operation was invoked at least once