Package | Description |
---|---|
org.corfudb.generator | |
org.corfudb.protocols.wireprotocol | |
org.corfudb.runtime | |
org.corfudb.runtime.clients | |
org.corfudb.runtime.object.transactions | |
org.corfudb.runtime.view |
Modifier and Type | Method and Description |
---|---|
void |
State.startSnapshotTx(Token snapshot) |
void |
State.updateTrimMark(Token newTrimMark) |
Modifier and Type | Field and Description |
---|---|
static Token |
Token.UNINITIALIZED |
Modifier and Type | Method and Description |
---|---|
default Token |
IMetadata.getToken() |
static Token |
Token.min(Token a,
Token b)
Given two tokens return the min
|
static Token |
Token.of(long epoch,
long sequence) |
Modifier and Type | Method and Description |
---|---|
int |
Token.compareTo(Token o) |
static Token |
Token.min(Token a,
Token b)
Given two tokens return the min
|
Constructor and Description |
---|
TokenResponse(Token token,
Map<UUID,Long> backpointerMap)
Constructor for TokenResponse.
|
TxResolutionInfo(UUID txId,
Token snapshotTimestamp)
Constructor for TxResolutionInfo.
|
TxResolutionInfo(UUID txId,
Token snapshotTimestamp,
Map<UUID,Set<byte[]>> conflictMap,
Map<UUID,Set<byte[]>> writeConflictParams)
Constructor for TxResolutionInfo.
|
Modifier and Type | Method and Description |
---|---|
Token |
CheckpointWriter.appendCheckpoint() |
Token |
MultiCheckpointWriter.appendCheckpoints(CorfuRuntime rt,
String author)
Checkpoint multiple SMRMaps.
|
Modifier and Type | Method and Description |
---|---|
void |
CheckpointWriter.startCheckpoint(Token txnSnapshot,
long vloVersion)
Append a checkpoint START record to this object's stream.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Boolean> |
LogUnitClient.fillHole(Token address)
Fill a hole at a given address.
|
CompletableFuture<Void> |
LogUnitClient.prefixTrim(Token address)
Send a prefix trim request that will trim the log up to a certain address
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractTransactionalContext.syncWithRetryUnsafe(VersionLockedObject vlo,
Token snapshotTimestamp,
ICorfuSMRProxyInternal proxy,
Consumer<VersionLockedObject> optimisticStreamSetter) |
Modifier and Type | Method and Description |
---|---|
Token |
AddressSpaceView.getTrimMark()
Get the first address in the address space.
|
Modifier and Type | Method and Description |
---|---|
void |
AddressSpaceView.prefixTrim(Token address)
Prefix trim the address space.
|
Copyright © 2019 CorfuDB. All rights reserved.