| Class |
Description |
| AbortedAsRequestedNoRollback |
Deprecated. |
| AbortedAsRequestedNoRollbackNoCleanup |
Deprecated. |
| Accessor |
Used to give public access to package-private members.
|
| AccessorUtil |
|
| ActiveTransactionRecord |
|
| ActiveTransactionRecord.ParsedHLC |
|
| ActiveTransactionRecordEntryNotFound |
|
| ActiveTransactionRecordFull |
This should not retry transactions.
|
| ActiveTransactionRecordNotFound |
|
| ATR |
|
| ATREntry |
|
| ATRIds |
|
| ATRStats |
Simple data class, so all fields are public.
|
| ATRUtil |
|
| AttemptContext |
Provides methods to allow an application's transaction logic to read, mutate, insert and delete documents, as well
as
commit or rollback the transaction.
|
| AttemptContextFactory |
|
| AttemptContextReactive |
Provides methods to allow an application's transaction logic to read, mutate, insert and delete documents, as well
as commit or rollback the transaction.
|
| AttemptExpired |
|
| AttemptNotFoundOnQuery |
Query does not recognise the passed txid.
|
| AttemptStates |
The possible states for a transaction attempt.
|
| CasMode |
Metadata related to the CAS.
|
| Cleaner |
Handles cleaning up expired/lost transactions.
|
| CleanerFactory |
Used for testing/mocking.
|
| CleanerMock |
|
| CleanerMockCreatorFactory |
Used for testing/mocking.
|
| CleanerMockFactory |
Used for testing/mocking.
|
| CleanupFailedEvent |
The cleanup attempt failed and was unable to cleanly return a CleanupResultEvent with !success
|
| CleanupRequest |
|
| ClientRecord |
Represents the ClientRecord doc, a single document that contains an entry for every client (app) current
participating
in the cleanup of 'lost' transactions.
|
| ClientRecordDetails |
Utility class to store the result of a client checking/updating the Client Record doc.
|
| ClientRecordFactory |
Used for testing/mocking.
|
| ClientRecordFactoryMock |
Used for testing/mocking.
|
| ClusterData |
Factors out some cluster-related functionality that is used in multiple places
|
| CommitNotPermitted |
The transaction is not allowed to commit in the current state.
|
| ConcurrentDoublyLinkedList<E> |
A concurrent linked-list implementation of a Deque (double-ended
queue).
|
| ConcurrentOperationsDetectedOnSameDocument |
Concurrent Key-Value operations on the same document have been detected.
|
| DebugUtil |
|
| DefaultAttemptContextFactory |
|
| DocRecord |
|
| DocumentAlreadyInTransaction |
|
| DocumentGetter |
Responsible for doing transaction-aware get()s.
|
| DocumentMetadata |
Stores some $document metadata from when the document is fetched
|
| DurabilityLevelUtil |
|
| ErrorClasses |
|
| ErrorClassException |
This is used to pass around an error of a particular error class.
|
| EventBusPersistedLogger |
Listens for events on the Couchbase event bus and logs some to the transactions persisted log.
|
| Extensions |
All protocol extensions known about by this implementation.
|
| ForwardCompatibility |
A mechanism to help ensure that older clients can be prevented from interacting with transactions created by future
clients that they do not know how to process.
|
| ForwardCompatibilityFailure |
This transaction has been prevented from interacting with documents or metadata owned by another transaction,
due to compatibility issues.
|
| ForwardCompatibilityRequiresRetry |
|
| ForwardCompatibilityStages |
Points in the protocol where forward compatibility can be checked.
|
| GenerateATRIds |
A tool for internal use that generates the fixed ATR ids.
|
| IllegalDocumentState |
Indicates that a document has been modified by a non-transactional write while it is in a transaction.
|
| LockTokens |
|
| LogDefer |
|
| LogDeferDocId |
|
| LogDeferThrowable |
|
| LostCleanupDistributed |
Runs the algorithm to find 'lost' transactions, distributing the work between clients.
|
| LostCleanupThreadEndedPrematurely |
|
| MarkableCrc32 |
A pure-java implementation of the CRC32 checksum that uses
the same polynomial as the built-in native CRC32.
|
| MergedTransactionConfig |
|
| MonoBridge<T> |
Protects against concurrent op cancellation.
|
| OperationTypes |
|
| OptionsWrapperUtil |
|
| PersistedLogReader |
|
| PersistedLogWriter |
Implements a persisted log for [LOG-PERSIST].
|
| PerTransactionConfig |
Tunables for an individual transaction.
|
| PerTransactionConfigBuilder |
Provides all configurable parameters for Couchbase transactions, in a builder format.
|
| PerTransactionQueryConfigBuilder |
Allows setting a per-transaction query configuration.
|
| PreviousOperationFailed |
A previous operation in the application's lambda failed, and so the currently-attempt operation is also not
permitted to proceed.
|
| QueryAccessor |
|
| QueryUtil |
|
| QuickFormat |
A high-performance version of StringFormat, optimized for short log messages.
|
| ReactiveLock |
A mutex pessimistic lock, compatible with reactive.
|
| ReactiveLock.Waiter |
|
| ReactiveSingleQueryTransactionResult |
Contains the result of a single query transaction.
|
| ReactiveWaitGroup |
Provides locking functionality in line with Go's WaitGroups, in a reactive compatible way.
|
| ReactiveWaitGroup.Waiter |
|
| RetryAtrCommit |
Indicates that committing the ATR entry should be retried.
|
| RetryOperation |
Indicates that this operation should be retried.
|
| RetryTransaction |
Causes the transaction to be retried.
|
| RollbackNotPermitted |
The transaction is not allowed to rollback in the current state.
|
| SchedulerUtil |
|
| SDKAccessUtil |
Provides access to package-private methods in package com.couchbase.client.core.msg.query.
|
| SDKAccessUtil |
Provides access to package-private methods in the top-level package com.couchbase.client.java.query.
|
| SDKAccessUtil |
Provides access to package-private methods in the top-level package com.couchbase.client.java.
|
| SerializationUtil |
|
| SimpleEventBusLogger |
Simple wrapper around logging to the Couchbase event bus.
|
| SingleQueryTransactionConfig |
|
| SingleQueryTransactionConfigBuilder |
Allows configuring a single-query-transaction.
|
| SingleQueryTransactionResult |
Contains the result of a single query transaction.
|
| SpanWrapper |
Wraps a RequestSpan, with the value-add that it automatically records how long the operation took for
transaction logging.
|
| SpanWrapperUtil |
|
| StagedMutation |
|
| StagedMutationType |
|
| Supported |
Defines what is support by this implementation (extensions and protocol version).
|
| TestAttemptContextFactory |
Can be used for testing transactions, but is for internal use only.
|
| TestAttemptContextReactive |
Can be used for testing transactions, but is for internal use only.
|
| TestFailAmbiguous |
Used only in testing: injects an error that will be handled as FAIL_AMBIGUOUS.
|
| TestFailHard |
Used only in testing: injects an error that will be handled as FAIL_HARD.
|
| TestFailOther |
Used only in testing: injects an error that will be handled as FAIL_OTHER.
|
| TestFailTransient |
Used only in testing: injects a FAIL_TRANSIENT error.
|
| ThreadStopRequested |
|
| TransactionAbortedExternally |
Another actor aborted this transaction and it was unable to commit.
|
| TransactionAlreadyAborted |
|
| TransactionAlreadyCommitted |
|
| TransactionAttempt |
Deprecated.
|
| TransactionCleanupAttempt |
Emitted when the lost transactions cleanup process discovered a lost transaction and attempted to clean it up.
|
| TransactionCleanupEndRunEvent |
Emitted periodically with a summary of cleanup data since the last event.
|
| TransactionCleanupStartRunEvent |
Emitted periodically with a summary of what will be done soon for cleanup.
|
| TransactionCommitAmbiguous |
The transaction expired at the point of trying to commit it.
|
| TransactionConfig |
Tunables for the transaction.
|
| TransactionConfigBuilder |
Provides all configurable parameters for Couchbase transactions, in a builder format.
|
| TransactionContext |
Stores some context related to a transaction.
|
| TransactionDurabilityLevel |
|
| TransactionEvent |
All transaction events derive from this.
|
| TransactionExpired |
The transaction could not be fully completed in the configured timeout.
|
| TransactionFailed |
The transaction failed to reach the Committed point.
|
| TransactionFields |
|
| TransactionGetResult |
Represents a value fetched from Couchbase, along with additional transactional metadata.
|
| TransactionInsertOptions |
|
| TransactionJsonDocumentStatus |
Deprecated. |
| TransactionLinks |
Stores the transaction links stored on each document in a transaction
|
| TransactionLogEvent |
|
| TransactionLogger |
A logger optimized for logging transactions-specific info.
|
| TransactionMock |
Can be used for testing transactions, but is for internal use only.
|
| TransactionOperationFailed |
This operation (such as a replace, get or insert) either failed or ambiguously succeeded.
|
| TransactionOperationFailed.FinalErrorToRaise |
|
| TransactionOperationFailedBuilder |
Allows constructing a TransactionOperationFailed.
|
| TransactionQueryConfigBuilder |
Allows setting a default query configuration for all transactions.
|
| TransactionQueryOptions |
Allows customizing various N1QL query options.
|
| TransactionReplaceOptions |
|
| TransactionResult |
Provides some debugging and logging facilities for tracking what happened during a transaction.
|
| Transactions |
The starting point for creating Couchbase transactions.
|
| TransactionsCleanup |
Owns cleanup threads.
|
| TransactionSerializedContext |
|
| TransactionsReactive |
An asynchronous version of Transactions, allowing transactions to be created and run in an asynchronous
manner. |
| TransactionsStarted |
An event that's fired when a Transactions object is successfully created. |
| TriFunction<T,U,V,R> |
|