Package | Description |
---|---|
org.corfudb.protocols.wireprotocol | |
org.corfudb.runtime.clients | |
org.corfudb.runtime.exceptions | |
org.corfudb.runtime.view |
Constructor and Description |
---|
TokenRequest(Long numTokens,
List<UUID> streams,
TxResolutionInfo conflictInfo)
Constructor for generating TokenRequest.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<TokenResponse> |
SequencerClient.nextToken(List<UUID> streamIDs,
long numTokens,
TxResolutionInfo conflictInfo)
Fetches the next available token from the sequencer.
|
Constructor and Description |
---|
TransactionAbortedException(TxResolutionInfo txResolutionInfo,
AbortCause abortCause,
Throwable cause,
AbstractTransactionalContext context) |
TransactionAbortedException(TxResolutionInfo txResolutionInfo,
byte[] conflictKey,
UUID conflictStream,
Long offendingAddress,
AbortCause abortCause,
AbstractTransactionalContext context)
Constructor.
|
TransactionAbortedException(TxResolutionInfo txResolutionInfo,
byte[] conflictKey,
UUID conflictStream,
Long offendingAddress,
AbortCause abortCause,
Throwable cause,
AbstractTransactionalContext context) |
Modifier and Type | Method and Description |
---|---|
long |
StreamsView.append(Object object,
TxResolutionInfo conflictInfo,
CacheOption cacheOption,
UUID... streamIDs)
Append to multiple streams simultaneously, possibly providing
information on how to resolve conflicts.
|
long |
StreamsView.append(Object object,
TxResolutionInfo conflictInfo,
UUID... streamIDs)
Append to multiple streams and caches the result.
|
TokenResponse |
SequencerView.next(TxResolutionInfo conflictInfo,
UUID... streamIds)
Acquire a token for a number of streams if there are no conflicts.
|
TokenResponse |
SequencerView.nextToken(Set<UUID> streamIDs,
int numTokens,
TxResolutionInfo conflictInfo)
Deprecated.
|
Copyright © 2019 CorfuDB. All rights reserved.