class InMemoryPendingOperationStore[Op <: HasProtocolVersionedWrapper[Op]] extends PendingOperationStore[Op]

Linear Supertypes
PendingOperationStore[Op], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. InMemoryPendingOperationStore
  2. PendingOperationStore
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new InMemoryPendingOperationStore(opCompanion: VersioningCompanion[Op])(implicit executionContext: ExecutionContext)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. def delete(synchronizerId: SynchronizerId, operationKey: String, operationName: NonEmptyString)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]

    Deletes a pending operation identified by its unique composite key (synchronizerId, operationKey, operationName).

    Deletes a pending operation identified by its unique composite key (synchronizerId, operationKey, operationName).

    This operation is idempotent. It succeeds regardless of whether the record existed prior to the call.

    synchronizerId

    The ID of the synchronizer scoping the operation application.

    operationKey

    A key to distinguish between multiple instances of the same operation.

    operationName

    The name of the operation to be executed.

    traceContext

    The context for tracing and logging.

    returns

    A future that completes when the deletion has finished.

    Definition Classes
    InMemoryPendingOperationStore → PendingOperationStore
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. implicit val executionContext: ExecutionContext
  10. def get(synchronizerId: SynchronizerId, operationKey: String, operationName: NonEmptyString)(implicit traceContext: TraceContext): OptionT[FutureUnlessShutdown, PendingOperation[Op]]

    Fetches a pending operation by its unique composite key (synchronizerId, operationKey, operationName).

    Fetches a pending operation by its unique composite key (synchronizerId, operationKey, operationName).

    synchronizerId

    The ID of the synchronizer scoping the operation application.

    operationKey

    A key to distinguish between multiple instances of the same operation.

    operationName

    The name of the operation to be executed.

    traceContext

    The context for tracing and logging.

    returns

    A future that completes with Some(operation) if found and valid, None if not found, or fails with a DbDeserializationException if the stored data is corrupt.

    Definition Classes
    InMemoryPendingOperationStore → PendingOperationStore
  11. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. def insert(operation: PendingOperation[Op])(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, ConflictingPendingOperationError, Unit]

    Atomically stores a pending operation, returning an error if a conflicting operation already exists.

    Atomically stores a pending operation, returning an error if a conflicting operation already exists.

    This check-and-insert operation is performed within a serializable transaction to prevent race conditions. The behavior depends on whether an operation with the same unique key (synchronizerId, key, name) already exists in the store:

    • If no operation with the key exists, the new operation is inserted.
    • If an identical operation already exists, the operation succeeds without making changes.
    • If an operation with the same key but different data exists, the operation fails with an error.
    operation

    The PendingOperation to insert.

    traceContext

    The context for tracing and logging.

    returns

    An EitherT that completes with:

    • Right(()) if the operation was successfully stored or an identical one already existed.
    • Left(ConflictingPendingOperationError) if a conflicting operation was found.
    Definition Classes
    InMemoryPendingOperationStore → PendingOperationStore
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. val opCompanion: VersioningCompanion[Op]
    Attributes
    protected
    Definition Classes
    InMemoryPendingOperationStore → PendingOperationStore
  19. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  20. def toString(): String
    Definition Classes
    AnyRef → Any
  21. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  23. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from PendingOperationStore[Op]

Inherited from AnyRef

Inherited from Any

Ungrouped