Package com.couchbase.client.core.transaction.util

Class CoreTransactionAttemptContextHooks

java.lang.Object

com.couchbase.client.core.transaction.util.CoreTransactionAttemptContextHooks

@Internal
public class CoreTransactionAttemptContextHooks
extends Object

Can be used for testing transactions, but is for internal use only.

Field Summary

Fields

Modifier and Type	Field	Description
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	afterAtrAborted
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	afterAtrCommit
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	afterAtrComplete
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	afterAtrPending
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	afterAtrRolledBack
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterDocCommitted
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterDocCommittedBeforeSavingCAS
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterDocRemovedPostRetry
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterDocRemovedPreRetry
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	afterDocsCommitted
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	afterDocsRemoved
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterGetComplete
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterQuery
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterRemoveStagedInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterRollbackDeleteInserted
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterRollbackReplaceOrRemove
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterStagedInsertComplete
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterStagedRemoveComplete
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	afterStagedReplaceComplete
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	beforeAtrAborted
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	beforeAtrCommit
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	beforeAtrCommitAmbiguityResolution
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	beforeAtrComplete
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	beforeAtrPending
Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>>	beforeAtrRolledBack
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeCheckATREntryForBlockingDoc
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeDocChangedDuringCommit
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeDocChangedDuringRollback
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeDocChangedDuringStaging
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeDocCommitted
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeDocGet
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeDocRemoved
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeDocRolledBack
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeGetDocInExistsDuringStagedInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeOverwritingStagedInsertRemoval
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeQuery
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeRemoveStagedInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeRollbackDeleteInserted
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeStagedInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeStagedRemove
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeStagedReplace
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeUnlockGet
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeUnlockInsert
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeUnlockQuery
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeUnlockRemove
BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>>	beforeUnlockReplace
TriFunction<CoreTransactionAttemptContext,String,Optional<String>,Boolean>	hasExpiredClientSideHook
static final String	HOOK_ATR_ABORT
static final String	HOOK_ATR_COMMIT
static final String	HOOK_ATR_COMMIT_AMBIGUITY_RESOLUTION
static final String	HOOK_ATR_COMPLETE
static final String	HOOK_ATR_PENDING
static final String	HOOK_ATR_ROLLBACK_COMPLETE
static final String	HOOK_BEFORE_COMMIT
static final String	HOOK_BEFORE_RETRY
static final String	HOOK_COMMIT_DOC
static final String	HOOK_COMMIT_DOC_CHANGED
static final String	HOOK_CREATE_STAGED_INSERT
static final String	HOOK_DELETE_INSERTED
static final String	HOOK_GET
static final String	HOOK_GET_MULTI
static final String	HOOK_GET_MULTI_INDIVIDUAL_DOCUMENT
static final String	HOOK_INSERT
static final String	HOOK_QUERY
static final String	HOOK_QUERY_BEGIN_WORK
static final String	HOOK_QUERY_COMMIT
static final String	HOOK_QUERY_KV_GET
static final String	HOOK_QUERY_KV_INSERT
static final String	HOOK_QUERY_KV_REMOVE
static final String	HOOK_QUERY_KV_REPLACE
static final String	HOOK_QUERY_ROLLBACK
static final String	HOOK_REMOVE
static final String	HOOK_REMOVE_DOC
static final String	HOOK_REMOVE_STAGED_INSERT
static final String	HOOK_REPLACE
static final String	HOOK_ROLLBACK
static final String	HOOK_ROLLBACK_DOC
static final String	HOOK_ROLLBACK_DOC_CHANGED
static final String	HOOK_STAGING_DOC_CHANGED
Function<CoreTransactionAttemptContext,Optional<String>>	randomAtrIdForVbucket
reactor.core.publisher.Mono<Integer>	standard

Constructor Summary

Constructors

Constructor	Description
CoreTransactionAttemptContextHooks()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

HOOK_ROLLBACK

public static final String HOOK_ROLLBACK

See Also:

• Constant Field Values

HOOK_GET

public static final String HOOK_GET

See Also:

• Constant Field Values

HOOK_INSERT

public static final String HOOK_INSERT

See Also:

• Constant Field Values

HOOK_REPLACE

public static final String HOOK_REPLACE

See Also:

• Constant Field Values

HOOK_REMOVE

public static final String HOOK_REMOVE

See Also:

• Constant Field Values

HOOK_BEFORE_COMMIT

public static final String HOOK_BEFORE_COMMIT

See Also:

• Constant Field Values

HOOK_ROLLBACK_DOC

public static final String HOOK_ROLLBACK_DOC

See Also:

• Constant Field Values

HOOK_DELETE_INSERTED

public static final String HOOK_DELETE_INSERTED

See Also:

• Constant Field Values

HOOK_REMOVE_STAGED_INSERT

public static final String HOOK_REMOVE_STAGED_INSERT

See Also:

• Constant Field Values

HOOK_CREATE_STAGED_INSERT

public static final String HOOK_CREATE_STAGED_INSERT

See Also:

• Constant Field Values

HOOK_REMOVE_DOC

public static final String HOOK_REMOVE_DOC

See Also:

• Constant Field Values

HOOK_COMMIT_DOC

public static final String HOOK_COMMIT_DOC

See Also:

• Constant Field Values

HOOK_COMMIT_DOC_CHANGED

public static final String HOOK_COMMIT_DOC_CHANGED

See Also:

• Constant Field Values

HOOK_STAGING_DOC_CHANGED

public static final String HOOK_STAGING_DOC_CHANGED

See Also:

• Constant Field Values

HOOK_ROLLBACK_DOC_CHANGED

public static final String HOOK_ROLLBACK_DOC_CHANGED

See Also:

• Constant Field Values

HOOK_QUERY

public static final String HOOK_QUERY

See Also:

• Constant Field Values

HOOK_QUERY_BEGIN_WORK

public static final String HOOK_QUERY_BEGIN_WORK

See Also:

• Constant Field Values

HOOK_QUERY_COMMIT

public static final String HOOK_QUERY_COMMIT

See Also:

• Constant Field Values

HOOK_QUERY_ROLLBACK

public static final String HOOK_QUERY_ROLLBACK

See Also:

• Constant Field Values

HOOK_QUERY_KV_GET

public static final String HOOK_QUERY_KV_GET

See Also:

• Constant Field Values

HOOK_QUERY_KV_REPLACE

public static final String HOOK_QUERY_KV_REPLACE

See Also:

• Constant Field Values

HOOK_QUERY_KV_REMOVE

public static final String HOOK_QUERY_KV_REMOVE

See Also:

• Constant Field Values

HOOK_QUERY_KV_INSERT

public static final String HOOK_QUERY_KV_INSERT

See Also:

• Constant Field Values

HOOK_BEFORE_RETRY

public static final String HOOK_BEFORE_RETRY

See Also:

• Constant Field Values

HOOK_GET_MULTI

public static final String HOOK_GET_MULTI

See Also:

• Constant Field Values

HOOK_GET_MULTI_INDIVIDUAL_DOCUMENT

public static final String HOOK_GET_MULTI_INDIVIDUAL_DOCUMENT

See Also:

• Constant Field Values

HOOK_ATR_COMMIT

public static final String HOOK_ATR_COMMIT

See Also:

• Constant Field Values

HOOK_ATR_COMMIT_AMBIGUITY_RESOLUTION

public static final String HOOK_ATR_COMMIT_AMBIGUITY_RESOLUTION

See Also:

• Constant Field Values

HOOK_ATR_ABORT

public static final String HOOK_ATR_ABORT

See Also:

• Constant Field Values

HOOK_ATR_ROLLBACK_COMPLETE

public static final String HOOK_ATR_ROLLBACK_COMPLETE

See Also:

• Constant Field Values

HOOK_ATR_PENDING

public static final String HOOK_ATR_PENDING

See Also:

• Constant Field Values

HOOK_ATR_COMPLETE

public static final String HOOK_ATR_COMPLETE

See Also:

• Constant Field Values

standard

public reactor.core.publisher.Mono<Integer> standard

beforeAtrCommit

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> beforeAtrCommit

beforeAtrCommitAmbiguityResolution

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> beforeAtrCommitAmbiguityResolution

afterAtrCommit

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> afterAtrCommit

beforeDocCommitted

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeDocCommitted

beforeRollbackDeleteInserted

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeRollbackDeleteInserted

afterDocCommittedBeforeSavingCAS

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterDocCommittedBeforeSavingCAS

afterDocCommitted

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterDocCommitted

beforeStagedInsert

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeStagedInsert

beforeStagedRemove

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeStagedRemove

beforeStagedReplace

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeStagedReplace

beforeDocRemoved

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeDocRemoved

beforeDocRolledBack

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeDocRolledBack

afterDocRemovedPreRetry

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterDocRemovedPreRetry

afterDocRemovedPostRetry

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterDocRemovedPostRetry

afterGetComplete

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterGetComplete

afterStagedReplaceComplete

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterStagedReplaceComplete

afterStagedRemoveComplete

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterStagedRemoveComplete

afterStagedInsertComplete

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterStagedInsertComplete

afterRollbackReplaceOrRemove

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterRollbackReplaceOrRemove

afterRollbackDeleteInserted

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterRollbackDeleteInserted

beforeCheckATREntryForBlockingDoc

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeCheckATREntryForBlockingDoc

beforeDocGet

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeDocGet

beforeGetDocInExistsDuringStagedInsert

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeGetDocInExistsDuringStagedInsert

beforeOverwritingStagedInsertRemoval

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeOverwritingStagedInsertRemoval

beforeRemoveStagedInsert

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeRemoveStagedInsert

afterRemoveStagedInsert

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterRemoveStagedInsert

afterDocsCommitted

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> afterDocsCommitted

afterDocsRemoved

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> afterDocsRemoved

afterAtrPending

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> afterAtrPending

beforeAtrPending

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> beforeAtrPending

beforeAtrComplete

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> beforeAtrComplete

beforeAtrRolledBack

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> beforeAtrRolledBack

afterAtrComplete

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> afterAtrComplete

beforeAtrAborted

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> beforeAtrAborted

afterAtrAborted

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> afterAtrAborted

afterAtrRolledBack

public Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<Integer>> afterAtrRolledBack

beforeQuery

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeQuery

afterQuery

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> afterQuery

randomAtrIdForVbucket

public Function<CoreTransactionAttemptContext,Optional<String>> randomAtrIdForVbucket

hasExpiredClientSideHook

public TriFunction<CoreTransactionAttemptContext,String,Optional<String>,Boolean> hasExpiredClientSideHook

beforeUnlockGet

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeUnlockGet

beforeUnlockInsert

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeUnlockInsert

beforeUnlockReplace

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeUnlockReplace

beforeUnlockRemove

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeUnlockRemove

beforeUnlockQuery

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeUnlockQuery

beforeDocChangedDuringStaging

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeDocChangedDuringStaging

beforeDocChangedDuringCommit

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeDocChangedDuringCommit

beforeDocChangedDuringRollback

public BiFunction<CoreTransactionAttemptContext,String,reactor.core.publisher.Mono<Integer>> beforeDocChangedDuringRollback

Constructor Details

CoreTransactionAttemptContextHooks

public CoreTransactionAttemptContextHooks()