Uses of Class
com.couchbase.client.core.transaction.util.ReactiveLock.Waiter
-
Packages that use ReactiveLock.Waiter Package Description com.couchbase.client.core.transaction com.couchbase.client.core.transaction.util -
-
Uses of ReactiveLock.Waiter in com.couchbase.client.core.transaction
Method parameters in com.couchbase.client.core.transaction with type arguments of type ReactiveLock.Waiter Modifier and Type Method Description <T> Mono<T>
CoreTransactionAttemptContext. doQueryOperation(String lockDebugIn, String statement, SpanWrapper pspan, TriFunction<Integer,AtomicReference<ReactiveLock.Waiter>,SpanWrapper,Mono<T>> op)
Doesn't need everything from doKVOperation, as queryWrapper already centralises a lot of logicMono<QueryResponse>
CoreTransactionAttemptContext. queryWrapperLocked(int sidx, String bucketName, String scopeName, String statement, com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode options, String hookPoint, boolean isBeginWork, boolean existingErrorCheck, com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode txdata, com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ArrayNode params, SpanWrapper span, boolean tximplicit, AtomicReference<ReactiveLock.Waiter> lockToken, boolean updateInternalState)
This will return a TransactionOperationFailedException if that's what query returns, else will return the error after passing through convertQueryError. -
Uses of ReactiveLock.Waiter in com.couchbase.client.core.transaction.util
Fields in com.couchbase.client.core.transaction.util declared as ReactiveLock.Waiter Modifier and Type Field Description ReactiveLock.Waiter
LockTokens. mutexToken
Methods in com.couchbase.client.core.transaction.util that return types with arguments of type ReactiveLock.Waiter Modifier and Type Method Description Mono<ReactiveLock.Waiter>
ReactiveLock. lock(String dbg, Duration timeout)
if the lock is unlocked, lock it, and continue else if the lock is locked, join the list of things waiting for it to be unlockedMethods in com.couchbase.client.core.transaction.util with parameters of type ReactiveLock.Waiter Modifier and Type Method Description Mono<Void>
ReactiveLock. unlock(ReactiveLock.Waiter waiter)
The thing currently waiting on this lock is now unlocking it.Mono<Void>
ReactiveLock. unlock(ReactiveLock.Waiter waiter, String extraDbg)
Mono<Void>
ReactiveLock. unlock(ReactiveLock.Waiter waiter, String extraDbg, boolean removeFromWaiters)
Constructors in com.couchbase.client.core.transaction.util with parameters of type ReactiveLock.Waiter Constructor Description LockTokens(ReactiveLock.Waiter mutexToken, ReactiveWaitGroup.Waiter waitGroupToken)
-