Uses of Class
com.couchbase.client.core.transaction.support.SpanWrapper
-
-
Uses of SpanWrapper in com.couchbase.client.core.transaction
Methods in com.couchbase.client.core.transaction that return SpanWrapper Modifier and Type Method Description SpanWrapper
CoreTransactionContext. span()
Methods in com.couchbase.client.core.transaction with parameters of type SpanWrapper Modifier and Type Method Description Mono<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 pspan, 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.Constructor parameters in com.couchbase.client.core.transaction with type arguments of type SpanWrapper Constructor Description CoreTransactionAttemptContext(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan, CoreTransactionAttemptContextHooks hooks)
-
Uses of SpanWrapper in com.couchbase.client.core.transaction.cleanup
Methods in com.couchbase.client.core.transaction.cleanup with parameters of type SpanWrapper Modifier and Type Method Description Mono<SubdocGetResponse>
ClientRecord. getClientRecord(CollectionIdentifier collection, SpanWrapper span)
Flux<TransactionCleanupAttemptEvent>
LostCleanupDistributed. handleATRCleanup(String bp, CollectionIdentifier atrCollection, String atrId, ActiveTransactionRecordStats stats, Duration safetyMargin, SpanWrapper pspan)
Looks at an ATR, finds any expired entries, and cleans them up.Mono<TransactionCleanupAttemptEvent>
TransactionsCleaner. performCleanup(CleanupRequest req, boolean isRegularCleanup, SpanWrapper pspan)
Mono<ClientRecordDetails>
ClientRecord. processClient(String clientUuid, CollectionIdentifier collection, CoreTransactionsConfig config, SpanWrapper pspan)
-
Uses of SpanWrapper in com.couchbase.client.core.transaction.components
-
Uses of SpanWrapper in com.couchbase.client.core.transaction.support
Methods in com.couchbase.client.core.transaction.support that return SpanWrapper Modifier and Type Method Description <T> SpanWrapper
SpanWrapper. attribute(String key, T value)
static SpanWrapper
SpanWrapperUtil. basic(SpanWrapper span, String op)
static SpanWrapper
SpanWrapper. create(RequestTracer tracer, String op, SpanWrapper parent)
static SpanWrapper
SpanWrapperUtil. createOp(CoreTransactionAttemptContext ctx, RequestTracer tracer, CollectionIdentifier collection, String id, String op, SpanWrapper attemptSpan)
Methods in com.couchbase.client.core.transaction.support with parameters of type SpanWrapper Modifier and Type Method Description static SpanWrapper
SpanWrapperUtil. basic(SpanWrapper span, String op)
static SpanWrapper
SpanWrapper. create(RequestTracer tracer, String op, SpanWrapper parent)
static SpanWrapper
SpanWrapperUtil. createOp(CoreTransactionAttemptContext ctx, RequestTracer tracer, CollectionIdentifier collection, String id, String op, SpanWrapper attemptSpan)
Method parameters in com.couchbase.client.core.transaction.support with type arguments of type SpanWrapper Modifier and Type Method Description CoreTransactionAttemptContext
TransactionAttemptContextFactory. create(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan)
-
Uses of SpanWrapper in com.couchbase.client.core.transaction.util
Methods in com.couchbase.client.core.transaction.util with parameters of type SpanWrapper Modifier and Type Method Description static Mono<InsertResponse>
TransactionKVHandler. insert(Core core, CollectionIdentifier collectionIdentifier, String id, byte[] transcodedContent, Duration timeout, Optional<DurabilityLevel> durabilityLevel, Map<String,Object> clientContext, SpanWrapper span)
static Mono<SubdocGetResponse>
TransactionKVHandler. lookupIn(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean accessDeleted, Map<String,Object> clientContext, SpanWrapper span, List<SubdocGetRequest.Command> commands)
static Mono<SubdocMutateResponse>
TransactionKVHandler. mutateIn(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean insertDocument, boolean upsertDocument, boolean reviveDocument, boolean accessDeleted, boolean createAsDeleted, long cas, Optional<DurabilityLevel> durabilityLevel, Map<String,Object> clientContext, SpanWrapper span, List<SubdocMutateRequest.Command> commands)
static Mono<SubdocMutateResponse>
TransactionKVHandler. mutateIn(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean insertDocument, boolean upsertDocument, boolean reviveDocument, boolean accessDeleted, boolean createAsDeleted, long cas, Optional<DurabilityLevel> durabilityLevel, Map<String,Object> clientContext, SpanWrapper span, List<SubdocMutateRequest.Command> commands, CoreTransactionLogger logger)
static Mono<RemoveResponse>
TransactionKVHandler. remove(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, long cas, Optional<DurabilityLevel> durabilityLevel, Map<String,Object> clientContext, SpanWrapper span)
Method parameters in com.couchbase.client.core.transaction.util with type arguments of type SpanWrapper Modifier and Type Method Description CoreTransactionAttemptContext
TestTransactionAttemptContextFactory. create(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan)
-