Package | Description |
---|---|
org.corfudb.runtime.view | |
org.corfudb.runtime.view.replication |
Modifier and Type | Method and Description |
---|---|
RuntimeLayout |
LayoutView.getRuntimeLayout() |
RuntimeLayout |
LayoutView.getRuntimeLayout(Layout layout) |
Modifier and Type | Method and Description |
---|---|
R |
AbstractView.LayoutFunction.apply(RuntimeLayout l) |
static Map<String,CompletableFuture<Boolean>> |
SealServersHelper.asyncSealServers(RuntimeLayout runtimeLayout)
Asynchronously seal all servers in layout by setting remote epochs.
|
Modifier and Type | Method and Description |
---|---|
protected void |
QuorumReplicationProtocol.holeFill(RuntimeLayout runtimeLayout,
long globalAddress)
Write a special hole filling entry using the
given address.
|
protected abstract void |
AbstractReplicationProtocol.holeFill(RuntimeLayout runtimeLayout,
long globalAddress)
Write a special hole filling entry using the
given address.
|
protected void |
ChainReplicationProtocol.holeFill(RuntimeLayout runtimeLayout,
long globalAddress)
Write a special hole filling entry using the
given address.
|
ILogData |
QuorumReplicationProtocol.peek(RuntimeLayout runtimeLayout,
long address)
Peek data from a given address.
|
ILogData |
IReplicationProtocol.peek(RuntimeLayout runtimeLayout,
long globalAddress)
Peek data from a given address.
|
ILogData |
ChainReplicationProtocol.peek(RuntimeLayout runtimeLayout,
long globalAddress)
Peek data from a given address.
|
ILogData |
IReplicationProtocol.read(RuntimeLayout runtimeLayout,
long globalAddress)
Read data from a given address.
|
ILogData |
AbstractReplicationProtocol.read(RuntimeLayout runtimeLayout,
long globalAddress)
Read data from a given address.
|
Map<Long,ILogData> |
QuorumReplicationProtocol.readAll(RuntimeLayout runtimeLayout,
List<Long> addresses,
boolean waitForWrite)
Read data from all the given addresses.
|
Map<Long,ILogData> |
IReplicationProtocol.readAll(RuntimeLayout runtimeLayout,
List<Long> addresses,
boolean waitForWrite)
Read data from all the given addresses.
|
Map<Long,ILogData> |
ChainReplicationProtocol.readAll(RuntimeLayout runtimeLayout,
List<Long> addresses,
boolean waitForWrite)
Reads a list of global addresses from the chain of log unit servers.
|
void |
QuorumReplicationProtocol.write(RuntimeLayout runtimeLayout,
ILogData data)
Write data to the log at the given address.
|
void |
IReplicationProtocol.write(RuntimeLayout runtimeLayout,
ILogData data)
Write data to the log at the given address.
|
void |
ChainReplicationProtocol.write(RuntimeLayout runtimeLayout,
ILogData data)
Write data to the log at the given address.
|
Copyright © 2019 CorfuDB. All rights reserved.