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
Consumer<CoreTransactionAttemptContext>	afterAtrAborted
Consumer<CoreTransactionAttemptContext>	afterAtrCommit
Consumer<CoreTransactionAttemptContext>	afterAtrComplete
Consumer<CoreTransactionAttemptContext>	afterAtrPending
Consumer<CoreTransactionAttemptContext>	afterAtrRolledBack
BiConsumer<CoreTransactionAttemptContext,String>	afterDocCommitted
BiConsumer<CoreTransactionAttemptContext,String>	afterDocCommittedBeforeSavingCAS
BiConsumer<CoreTransactionAttemptContext,String>	afterDocRemovedPostRetry
BiConsumer<CoreTransactionAttemptContext,String>	afterDocRemovedPreRetry
Consumer<CoreTransactionAttemptContext>	afterDocsCommitted
Consumer<CoreTransactionAttemptContext>	afterDocsRemoved
BiConsumer<CoreTransactionAttemptContext,String>	afterGetComplete
BiConsumer<CoreTransactionAttemptContext,String>	afterQuery
BiConsumer<CoreTransactionAttemptContext,String>	afterRemoveStagedInsert
BiConsumer<CoreTransactionAttemptContext,String>	afterRollbackDeleteInserted
BiConsumer<CoreTransactionAttemptContext,String>	afterRollbackReplaceOrRemove
BiConsumer<CoreTransactionAttemptContext,String>	afterStagedInsertComplete
BiConsumer<CoreTransactionAttemptContext,String>	afterStagedRemoveComplete
BiConsumer<CoreTransactionAttemptContext,String>	afterStagedReplaceComplete
Consumer<CoreTransactionAttemptContext>	beforeAtrAborted
Consumer<CoreTransactionAttemptContext>	beforeAtrCommit
Consumer<CoreTransactionAttemptContext>	beforeAtrCommitAmbiguityResolution
Consumer<CoreTransactionAttemptContext>	beforeAtrComplete
Consumer<CoreTransactionAttemptContext>	beforeAtrPending
Consumer<CoreTransactionAttemptContext>	beforeAtrRolledBack
BiConsumer<CoreTransactionAttemptContext,String>	beforeCheckATREntryForBlockingDoc
BiConsumer<CoreTransactionAttemptContext,String>	beforeDocChangedDuringCommit
BiConsumer<CoreTransactionAttemptContext,String>	beforeDocChangedDuringRollback
BiConsumer<CoreTransactionAttemptContext,String>	beforeDocChangedDuringStaging
BiConsumer<CoreTransactionAttemptContext,String>	beforeDocCommitted
BiConsumer<CoreTransactionAttemptContext,String>	beforeDocGet
BiConsumer<CoreTransactionAttemptContext,String>	beforeDocRemoved
BiConsumer<CoreTransactionAttemptContext,String>	beforeDocRolledBack
BiConsumer<CoreTransactionAttemptContext,String>	beforeGetDocInExistsDuringStagedInsert
BiConsumer<CoreTransactionAttemptContext,String>	beforeOverwritingStagedInsertRemoval
BiConsumer<CoreTransactionAttemptContext,String>	beforeQuery
BiConsumer<CoreTransactionAttemptContext,String>	beforeRemoveStagedInsert
BiConsumer<CoreTransactionAttemptContext,String>	beforeRollbackDeleteInserted
BiConsumer<CoreTransactionAttemptContext,String>	beforeStagedInsert
BiConsumer<CoreTransactionAttemptContext,String>	beforeStagedRemove
BiConsumer<CoreTransactionAttemptContext,String>	beforeStagedReplace
BiConsumer<CoreTransactionAttemptContext,String>	beforeUnlockGet
BiConsumer<CoreTransactionAttemptContext,String>	beforeUnlockInsert
BiConsumer<CoreTransactionAttemptContext,String>	beforeUnlockQuery
BiConsumer<CoreTransactionAttemptContext,String>	beforeUnlockRemove
BiConsumer<CoreTransactionAttemptContext,String>	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

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

beforeAtrCommit

public Consumer<CoreTransactionAttemptContext> beforeAtrCommit

beforeAtrCommitAmbiguityResolution

public Consumer<CoreTransactionAttemptContext> beforeAtrCommitAmbiguityResolution

afterAtrCommit

public Consumer<CoreTransactionAttemptContext> afterAtrCommit

beforeDocCommitted

public BiConsumer<CoreTransactionAttemptContext,String> beforeDocCommitted

beforeRollbackDeleteInserted

public BiConsumer<CoreTransactionAttemptContext,String> beforeRollbackDeleteInserted

afterDocCommittedBeforeSavingCAS

public BiConsumer<CoreTransactionAttemptContext,String> afterDocCommittedBeforeSavingCAS

afterDocCommitted

public BiConsumer<CoreTransactionAttemptContext,String> afterDocCommitted

beforeStagedInsert

public BiConsumer<CoreTransactionAttemptContext,String> beforeStagedInsert

beforeStagedRemove

public BiConsumer<CoreTransactionAttemptContext,String> beforeStagedRemove

beforeStagedReplace

public BiConsumer<CoreTransactionAttemptContext,String> beforeStagedReplace

beforeDocRemoved

public BiConsumer<CoreTransactionAttemptContext,String> beforeDocRemoved

beforeDocRolledBack

public BiConsumer<CoreTransactionAttemptContext,String> beforeDocRolledBack

afterDocRemovedPreRetry

public BiConsumer<CoreTransactionAttemptContext,String> afterDocRemovedPreRetry

afterDocRemovedPostRetry

public BiConsumer<CoreTransactionAttemptContext,String> afterDocRemovedPostRetry

afterGetComplete

public BiConsumer<CoreTransactionAttemptContext,String> afterGetComplete

afterStagedReplaceComplete

public BiConsumer<CoreTransactionAttemptContext,String> afterStagedReplaceComplete

afterStagedRemoveComplete

public BiConsumer<CoreTransactionAttemptContext,String> afterStagedRemoveComplete

afterStagedInsertComplete

public BiConsumer<CoreTransactionAttemptContext,String> afterStagedInsertComplete

afterRollbackReplaceOrRemove

public BiConsumer<CoreTransactionAttemptContext,String> afterRollbackReplaceOrRemove

afterRollbackDeleteInserted

public BiConsumer<CoreTransactionAttemptContext,String> afterRollbackDeleteInserted

beforeCheckATREntryForBlockingDoc

public BiConsumer<CoreTransactionAttemptContext,String> beforeCheckATREntryForBlockingDoc

beforeDocGet

public BiConsumer<CoreTransactionAttemptContext,String> beforeDocGet

beforeGetDocInExistsDuringStagedInsert

public BiConsumer<CoreTransactionAttemptContext,String> beforeGetDocInExistsDuringStagedInsert

beforeOverwritingStagedInsertRemoval

public BiConsumer<CoreTransactionAttemptContext,String> beforeOverwritingStagedInsertRemoval

beforeRemoveStagedInsert

public BiConsumer<CoreTransactionAttemptContext,String> beforeRemoveStagedInsert

afterRemoveStagedInsert

public BiConsumer<CoreTransactionAttemptContext,String> afterRemoveStagedInsert

afterDocsCommitted

public Consumer<CoreTransactionAttemptContext> afterDocsCommitted

afterDocsRemoved

public Consumer<CoreTransactionAttemptContext> afterDocsRemoved

afterAtrPending

public Consumer<CoreTransactionAttemptContext> afterAtrPending

beforeAtrPending

public Consumer<CoreTransactionAttemptContext> beforeAtrPending

beforeAtrComplete

public Consumer<CoreTransactionAttemptContext> beforeAtrComplete

beforeAtrRolledBack

public Consumer<CoreTransactionAttemptContext> beforeAtrRolledBack

afterAtrComplete

public Consumer<CoreTransactionAttemptContext> afterAtrComplete

beforeAtrAborted

public Consumer<CoreTransactionAttemptContext> beforeAtrAborted

afterAtrAborted

public Consumer<CoreTransactionAttemptContext> afterAtrAborted

afterAtrRolledBack

public Consumer<CoreTransactionAttemptContext> afterAtrRolledBack

beforeQuery

public BiConsumer<CoreTransactionAttemptContext,String> beforeQuery

afterQuery

public BiConsumer<CoreTransactionAttemptContext,String> afterQuery

randomAtrIdForVbucket

public Function<CoreTransactionAttemptContext,Optional<String>> randomAtrIdForVbucket

hasExpiredClientSideHook

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

beforeUnlockGet

public BiConsumer<CoreTransactionAttemptContext,String> beforeUnlockGet

beforeUnlockInsert

public BiConsumer<CoreTransactionAttemptContext,String> beforeUnlockInsert

beforeUnlockReplace

public BiConsumer<CoreTransactionAttemptContext,String> beforeUnlockReplace

beforeUnlockRemove

public BiConsumer<CoreTransactionAttemptContext,String> beforeUnlockRemove

beforeUnlockQuery

public BiConsumer<CoreTransactionAttemptContext,String> beforeUnlockQuery

beforeDocChangedDuringStaging

public BiConsumer<CoreTransactionAttemptContext,String> beforeDocChangedDuringStaging

beforeDocChangedDuringCommit

public BiConsumer<CoreTransactionAttemptContext,String> beforeDocChangedDuringCommit

beforeDocChangedDuringRollback

public BiConsumer<CoreTransactionAttemptContext,String> beforeDocChangedDuringRollback

Constructor Details

CoreTransactionAttemptContextHooks

public CoreTransactionAttemptContextHooks()