Package | Description |
---|---|
org.corfudb.infrastructure.log | |
org.corfudb.protocols.wireprotocol | |
org.corfudb.runtime.clients |
Modifier and Type | Method and Description |
---|---|
LogData |
StreamLogFiles.read(long address) |
LogData |
StreamLog.read(long address)
Given an address, read the corresponding stream entry.
|
LogData |
InMemoryStreamLog.read(long address) |
Modifier and Type | Method and Description |
---|---|
void |
StreamLogFiles.append(long address,
LogData entry) |
void |
StreamLog.append(long address,
LogData entry)
Append an entry to the stream log.
|
void |
InMemoryStreamLog.append(long address,
LogData entry) |
default void |
StreamLogWithRankedAddressSpace.assertAppendPermittedUnsafe(long address,
LogData newEntry)
Check whether the data can be appended to a given log address.
|
default OverwriteCause |
StreamLog.getOverwriteCauseForAddress(long address,
LogData entry)
Get overwrite cause for a given address.
|
void |
LogMetadata.update(LogData entry) |
Modifier and Type | Method and Description |
---|---|
void |
StreamLogFiles.append(List<LogData> range) |
void |
StreamLog.append(List<LogData> entries)
Append a range of consecutive entries ordered by their addresses.
|
void |
InMemoryStreamLog.append(List<LogData> entries) |
void |
LogMetadata.update(List<LogData> entries) |
Modifier and Type | Field and Description |
---|---|
static LogData |
LogData.EMPTY |
Modifier and Type | Method and Description |
---|---|
static LogData |
LogData.getEmpty(long address) |
static LogData |
LogData.getHole(long address) |
static LogData |
LogData.getTrimmed(long address) |
Modifier and Type | Method and Description |
---|---|
void |
ReadResponse.put(Long address,
LogData data) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Boolean> |
LogUnitClient.writeRange(List<LogData> range)
Sends a request to write a list of addresses.
|
Copyright © 2019 CorfuDB. All rights reserved.