Package com.couchbase.client.core.transaction

Class CoreTransactions

java.lang.Object

com.couchbase.client.core.transaction.CoreTransactions

@Internal
public class CoreTransactions
extends Object

Constructor Summary

Constructors

Constructor	Description
CoreTransactions(Core core, CoreTransactionsConfig config)

Method Summary

Modifier and Type	Method	Description
CoreTransactionsConfig	config()
static String	configDebug(CoreTransactionsConfig config, CoreTransactionOptions perConfig, Core core)
Core	core()
CoreTransactionAttemptContext	createAttemptContext(CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId)
CoreTransactionResult	executeTransaction(Supplier<CoreTransactionAttemptContext> createAttempt, CoreTransactionContext overall, Function<CoreTransactionAttemptContext,Void> transactionLogic, boolean singleQueryTransactionMode)
CoreQueryResult	queryBlocking(String statement, CoreQueryContext qc, CoreQueryOptions queryOptions, Optional<RequestSpan> parentSpan)
CoreTransactionResult	run(Function<CoreTransactionAttemptContext,?> transactionLogic, CoreTransactionOptions perConfig)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CoreTransactions

public CoreTransactions(Core core,
 CoreTransactionsConfig config)

Method Details

core

public Core core()

config

public CoreTransactionsConfig config()

executeTransaction

public CoreTransactionResult executeTransaction(Supplier<CoreTransactionAttemptContext> createAttempt,
 CoreTransactionContext overall,
 Function<CoreTransactionAttemptContext,Void> transactionLogic,
 boolean singleQueryTransactionMode)

createAttemptContext

public CoreTransactionAttemptContext createAttemptContext(CoreTransactionContext overall,
 CoreMergedTransactionConfig config,
 String attemptId)

run

public CoreTransactionResult run(Function<CoreTransactionAttemptContext,?> transactionLogic,
 @Nullable
 CoreTransactionOptions perConfig)

configDebug

public static String configDebug(CoreTransactionsConfig config,
 @Nullable
 CoreTransactionOptions perConfig,
 Core core)

queryBlocking

public CoreQueryResult queryBlocking(String statement,
 @Nullable
 CoreQueryContext qc,
 CoreQueryOptions queryOptions,
 Optional<RequestSpan> parentSpan)