Package | Description |
---|---|
org.corfudb.infrastructure.management | |
org.corfudb.infrastructure.management.failuredetector | |
org.corfudb.protocols.wireprotocol |
Modifier and Type | Method and Description |
---|---|
ClusterState |
ClusterStateCollector.collectClusterState(long epoch,
SequencerMetrics sequencerMetrics)
Provides cluster state
|
ClusterState |
ClusterStateAggregator.getAggregatedState()
Aggregates state from a list of poll reports.
|
ClusterState |
ClusterStateContext.getClusterView()
Returns current cluster state.
|
Modifier and Type | Method and Description |
---|---|
Optional<NodeRank> |
ClusterAdvisor.failedServer(ClusterState clusterState,
List<String> unresponsiveServers)
Provide a list of servers in the Corfu cluster which according to the underlying algorithm
for
ClusterType have failed. |
Optional<NodeRank> |
CompleteGraphAdvisor.failedServer(ClusterState clusterState,
List<String> unresponsiveServers)
Provides list of servers from a given layout(epoch) that this implementation of
COMPLETE_GRAPH algorithm has determined as failed.
|
ClusterGraph |
ClusterAdvisor.getGraph(ClusterState clusterState)
Provides a cluster graph generated from the
ClusterState |
ClusterGraph |
CompleteGraphAdvisor.getGraph(ClusterState clusterState)
Returns a new cluster graph from the cluster state
|
Optional<NodeRank> |
ClusterAdvisor.healedServer(ClusterState clusterState,
List<String> unresponsiveServers)
Provide a server in the Corfu cluster which according to the underlying algorithm
for
ClusterType have healed. |
Optional<NodeRank> |
CompleteGraphAdvisor.healedServer(ClusterState clusterState,
List<String> unresponsiveServers)
Provide a server considered to have healed in the Corfu cluster according to
the COMPLETE_GRAPH implementation of algorithm for
ClusterType . |
Modifier and Type | Method and Description |
---|---|
static ClusterGraph |
ClusterGraph.toClusterGraph(ClusterState cluster,
String localNode)
Transform a cluster state to the cluster graph.
|
Modifier and Type | Method and Description |
---|---|
static ClusterState |
ClusterState.buildClusterState(String localEndpoint,
NodeState... states) |
Copyright © 2019 CorfuDB. All rights reserved.