Package | Description |
---|---|
org.corfudb.infrastructure.orchestrator.actions | |
org.corfudb.runtime.view |
Modifier and Type | Method and Description |
---|---|
static void |
StateTransfer.transfer(Layout layout,
Set<String> endpoints,
CorfuRuntime runtime,
Layout.LayoutSegment segment)
Fetch and propagate the trimMark to the new/healing nodes.
|
Modifier and Type | Method and Description |
---|---|
Layout.LayoutSegment |
Layout.getFirstSegment()
Get the first segment.
|
Layout.LayoutSegment |
Layout.getLatestSegment()
Return latest segment.
|
Layout.LayoutSegment |
Layout.getSegment(long globalAddress)
Return layout segment.
|
Modifier and Type | Method and Description |
---|---|
List<Layout.LayoutSegment> |
Layout.getPrefixSegments(long globalAddress)
Return a list of segments which contain global
addresses less than or equal to the given address
(known as the prefix).
|
List<Layout.LayoutSegment> |
Layout.getSegmentsForEndpoint(String endpoint)
Return all the segments that an endpoint participates in.
|
Modifier and Type | Method and Description |
---|---|
abstract ClusterStatusReport.ClusterStatus |
Layout.ReplicationMode.getClusterHealthForSegment(Layout.LayoutSegment layoutSegment,
Set<String> responsiveNodes)
Returns the health of the cluster for a given segment.
|
abstract void |
Layout.ReplicationMode.validateSegmentSeal(Layout.LayoutSegment layoutSegment,
Map<String,CompletableFuture<Boolean>> completableFutureMap)
Seals the layout segment.
|
static void |
SealServersHelper.waitForChainSegmentSeal(Layout.LayoutSegment layoutSegment,
Map<String,CompletableFuture<Boolean>> completableFutureMap)
Wait for at least one log unit servers in every stripe to be sealed.
|
static void |
SealServersHelper.waitForQuorumSegmentSeal(Layout.LayoutSegment layoutSegment,
Map<String,CompletableFuture<Boolean>> completableFutureMap)
Wait for a quorum of log unit servers to respond to be sealed.
|
Constructor and Description |
---|
Layout(List<String> layoutServers,
List<String> sequencers,
List<Layout.LayoutSegment> segments,
List<String> unresponsiveServers,
long epoch,
UUID clusterId)
Defensive constructor since we can create a Layout from a JSON file.
|
Layout(List<String> layoutServers,
List<String> sequencers,
List<Layout.LayoutSegment> segments,
long epoch,
UUID clusterId) |
Copyright © 2019 CorfuDB. All rights reserved.