object WithDbLock
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- WithDbLock
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- sealed trait WithDbLockError extends Product with Serializable with PrettyPrinting
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withDbLock[A, B](lockName: String, lockCounter: DbLockCounter, timeouts: ProcessingTimeout, storage: Storage, clock: Clock, loggerFactory: NamedLoggerFactory, connectionConfig: DbLockedConnectionConfig)(fn: => EitherT[FutureUnlessShutdown, A, B])(implicit arg0: Pretty[A], traceContext: TraceContext, executionContext: ExecutionContext, closeContext: CloseContext): EitherT[FutureUnlessShutdown, WithDbLockError, B]
- def withDbLock[A, B](lockName: String, lockCounter: DbLockCounter, timeouts: ProcessingTimeout, dbConfig: DbConfig, connectionConfig: DbLockedConnectionConfig, profile: Profile, metrics: DbQueueMetrics, clock: Clock, loggerFactory: NamedLoggerFactory)(fn: => EitherT[FutureUnlessShutdown, A, B])(implicit arg0: Pretty[A], traceContext: TraceContext, executionContext: ExecutionContext, closeContext: CloseContext): EitherT[FutureUnlessShutdown, WithDbLockError, B]
Attempts to acquire an exclusive lock with the given
lockCounterand will block until this occurs.Attempts to acquire an exclusive lock with the given
lockCounterand will block until this occurs. The block will be executed once the lock is acquired and finally the lock as well as the connection holding the lock will be released.If the provided
storageinstance does not support creating DB provided application locks the block will be directly run with no synchronization. This is considered reasonable as this is mainly used for synchronizing multiple processes around a shared database, however when using in-memory or h2 stores this storage is unable or unlikely to be shared, and is likely the only process running the operation. - object WithDbLockError extends Serializable