| Modifier and Type | Method and Description |
|---|---|
long |
ExpirationAfterWriteStrategy.calculateTimeToLiveMillis(RemoteBucketState state,
long currentTimeNanos)
Calculates the time to live for bucket that is going to be persisted to the remote storage
|
| Modifier and Type | Method and Description |
|---|---|
long |
FixedTtlExpirationAfterWriteStrategy.calculateTimeToLiveMillis(RemoteBucketState state,
long currentTimeNanos) |
long |
NoneExpirationAfterWriteStrategy.calculateTimeToLiveMillis(RemoteBucketState state,
long currentTimeNanos) |
long |
BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy.calculateTimeToLiveMillis(RemoteBucketState state,
long currentTimeNanos) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CompareAndSwapOperation.compareAndSwap(byte[] originalData,
byte[] newData,
RemoteBucketState newState,
Optional<Long> timeoutNanos)
Compares and swap data associated with key
|
CompletableFuture<Boolean> |
AsyncCompareAndSwapOperation.compareAndSwap(byte[] originalData,
byte[] newData,
RemoteBucketState newState,
Optional<Long> timeoutNanos)
Compares and swap data associated with key
|
| Modifier and Type | Method and Description |
|---|---|
void |
LockBasedTransaction.create(byte[] data,
RemoteBucketState state,
Optional<Long> timeoutNanos)
Creates the data by the key associated with this transaction.
|
void |
LockBasedTransaction.update(byte[] data,
RemoteBucketState newState,
Optional<Long> timeoutNanos)
Updates the data by the key associated with this transaction.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SelectForUpdateBasedTransaction.update(byte[] data,
RemoteBucketState newState,
Optional<Long> timeoutNanos)
Updates the data by the key associated with this transaction.
|
| Modifier and Type | Field and Description |
|---|---|
static SerializationHandle<RemoteBucketState> |
RemoteBucketState.SERIALIZATION_HANDLE |
| Modifier and Type | Method and Description |
|---|---|
RemoteBucketState |
RemoteBucketState.copy() |
RemoteBucketState |
MutableBucketEntry.get() |
RemoteBucketState |
RemoteVerboseResult.getState() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
RemoteBucketState.equalsByContent(RemoteBucketState other) |
void |
MutableBucketEntry.set(RemoteBucketState state) |
protected abstract void |
AbstractBinaryTransaction.setRawState(byte[] newStateBytes,
RemoteBucketState newState) |
| Constructor and Description |
|---|
MutableBucketEntry(RemoteBucketState state) |
RemoteVerboseResult(long operationTimeNanos,
int resultTypeId,
T value,
RemoteBucketState state) |
| Modifier and Type | Method and Description |
|---|---|
CommandResult<RemoteBucketState> |
CreateSnapshotCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
| Modifier and Type | Method and Description |
|---|---|
long |
CreateSnapshotCommand.getConsumedTokens(RemoteBucketState result) |
| Modifier and Type | Method and Description |
|---|---|
static RemoteBucketState |
InternalSerializationHelper.deserializeState(byte[] bytes) |
| Modifier and Type | Method and Description |
|---|---|
static byte[] |
InternalSerializationHelper.serializeState(RemoteBucketState state,
Version backwardCompatibilityVersion) |
Copyright © 2024. All rights reserved.