Package com.couchbase.client.core.transaction.cleanup

Class ClientRecord

java.lang.Object

com.couchbase.client.core.transaction.cleanup.ClientRecord

@Internal
public class ClientRecord
extends Object

Represents the ClientRecord doc, a single document that contains an entry for every client (app) current participating in the cleanup of 'lost' transactions.

ClientRecord isn't as contended as it appears. It's only read and written to by each client once per cleanup window (default for this is 60 seconds). It does remain a single point of failure, but with a sensible number of replicas this is unlikely to be a problem.

All writes are non-durable. If a write is rolled back then it's not critical, it will just take a little longer to find lost txns.

Author:

Graham Pople

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLIENT_RECORD_DOC_ID
static final String	FIELD_CLIENTS
static final String	FIELD_OVERRIDE
static final String	FIELD_OVERRIDE_ENABLED
static final String	FIELD_OVERRIDE_EXPIRES
static final String	FIELD_RECORDS

Constructor Summary

Constructors

Constructor	Description
ClientRecord(Core core)

Method Summary

Modifier and Type	Method	Description
protected reactor.core.publisher.Mono<Integer>	beforeCreateRecord(ClientRecord self)
protected reactor.core.publisher.Mono<Integer>	beforeGetRecord(ClientRecord self)
protected reactor.core.publisher.Mono<Integer>	beforeRemoveClient(ClientRecord self)
protected reactor.core.publisher.Mono<Integer>	beforeUpdateCAS(ClientRecord self)	Deprecated.
protected reactor.core.publisher.Mono<Integer>	beforeUpdateRecord(ClientRecord self)
reactor.core.publisher.Mono<CoreSubdocGetResult>	getClientRecord(CollectionIdentifier collection, SpanWrapper span)
static ClientRecordDetails	parseClientRecord(CoreSubdocGetResult clientRecord, String clientUuid)
reactor.core.publisher.Mono<ClientRecordDetails>	processClient(String clientUuid, CollectionIdentifier collection, CoreTransactionsConfig config, SpanWrapper pspan)
reactor.core.publisher.Flux<Void>	removeClientFromClientRecord(String clientUuid, Duration timeout, Set<CollectionIdentifier> collections)	Called on shutdown to cleanly remove a client from the client-record.
reactor.core.publisher.Flux<Void>	removeClientFromClientRecord(String clientUuid, Set<CollectionIdentifier> cleanupSet)

Methods inherited from class java.lang.Object

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

Field Details

CLIENT_RECORD_DOC_ID

public static final String CLIENT_RECORD_DOC_ID

See Also:

• Constant Field Values

FIELD_RECORDS

public static final String FIELD_RECORDS

See Also:

• Constant Field Values

FIELD_CLIENTS

public static final String FIELD_CLIENTS

See Also:

• Constant Field Values

FIELD_OVERRIDE

public static final String FIELD_OVERRIDE

See Also:

• Constant Field Values

FIELD_OVERRIDE_ENABLED

public static final String FIELD_OVERRIDE_ENABLED

See Also:

• Constant Field Values

FIELD_OVERRIDE_EXPIRES

public static final String FIELD_OVERRIDE_EXPIRES

See Also:

• Constant Field Values

Constructor Details

ClientRecord

public ClientRecord(Core core)

Method Details

removeClientFromClientRecord

public reactor.core.publisher.Flux<Void> removeClientFromClientRecord(String clientUuid,
 Set<CollectionIdentifier> cleanupSet)

removeClientFromClientRecord

public reactor.core.publisher.Flux<Void> removeClientFromClientRecord(String clientUuid,
 Duration timeout,
 Set<CollectionIdentifier> collections)

Called on shutdown to cleanly remove a client from the client-record.

parseClientRecord

public static ClientRecordDetails parseClientRecord(CoreSubdocGetResult clientRecord,
 String clientUuid)

getClientRecord

public reactor.core.publisher.Mono<CoreSubdocGetResult> getClientRecord(CollectionIdentifier collection,
 @Nullable
 SpanWrapper span)

processClient

public reactor.core.publisher.Mono<ClientRecordDetails> processClient(String clientUuid,
 CollectionIdentifier collection,
 CoreTransactionsConfig config,
 @Nullable
 SpanWrapper pspan)

beforeCreateRecord

protected reactor.core.publisher.Mono<Integer> beforeCreateRecord(ClientRecord self)

beforeRemoveClient

protected reactor.core.publisher.Mono<Integer> beforeRemoveClient(ClientRecord self)

beforeUpdateCAS

@Deprecated
protected reactor.core.publisher.Mono<Integer> beforeUpdateCAS(ClientRecord self)

Deprecated.

beforeGetRecord

protected reactor.core.publisher.Mono<Integer> beforeGetRecord(ClientRecord self)

beforeUpdateRecord

protected reactor.core.publisher.Mono<Integer> beforeUpdateRecord(ClientRecord self)