Package | Description |
---|---|
com.couchbase.client.core.transaction.cleanup | |
com.couchbase.client.core.transaction.components |
Modifier and Type | Field and Description |
---|---|
Collection<ActiveTransactionRecordEntry> |
ActiveTransactionRecordStats.expired |
Modifier and Type | Method and Description |
---|---|
Optional<ActiveTransactionRecordEntry> |
ActiveTransactionRecordStats.oldest() |
Modifier and Type | Method and Description |
---|---|
Mono<TransactionCleanupAttemptEvent> |
TransactionsCleaner.cleanupATREntry(CollectionIdentifier atrCollection,
String atrId,
String attemptId,
ActiveTransactionRecordEntry atrEntry,
boolean isRegularCleanup)
Kept purely for backwards compatibility with FIT performer.
|
static CleanupRequest |
CleanupRequest.fromAtrEntry(CollectionIdentifier atrCollection,
ActiveTransactionRecordEntry atrEntry) |
Modifier and Type | Method and Description |
---|---|
static ActiveTransactionRecordEntry |
ActiveTransactionRecord.createFrom(String atrBucket,
String atrId,
com.couchbase.client.core.deps.com.fasterxml.jackson.databind.JsonNode entry,
String attemptId,
long cas) |
Modifier and Type | Method and Description |
---|---|
List<ActiveTransactionRecordEntry> |
ActiveTransactionRecords.entries() |
static Mono<Optional<ActiveTransactionRecordEntry>> |
ActiveTransactionRecord.findEntryForTransaction(Core core,
CollectionIdentifier atrCollection,
String atrId,
String attemptId,
CoreMergedTransactionConfig config,
SpanWrapper pspan,
CoreTransactionLogger logger) |
static Mono<Optional<ActiveTransactionRecordEntry>> |
ActiveTransactionRecord.findEntryForTransaction(Core core,
CollectionIdentifier atrCollection,
String atrId,
String attemptId,
CoreMergedTransactionConfig config,
SpanWrapper pspan,
CoreTransactionLogger logger,
MeteringUnits.MeteringUnitsBuilder units) |
Constructor and Description |
---|
ActiveTransactionRecords(String id,
CollectionIdentifier collection,
long casInNanos,
List<ActiveTransactionRecordEntry> entries,
CasMode casMode) |
Copyright © 2024 Couchbase, Inc.. All rights reserved.