org.corfudb.infrastructure.management

Class ClusterStateCollector

java.lang.Object

org.corfudb.infrastructure.management.ClusterStateCollector

public class ClusterStateCollector
extends Object

Collects information about cluster state. Provides list of servers in the cluster with higher epochs. Builds the ClusterState and local NodeState. The collector navigates via list of requests represented as CompletableFuture-s and collecting information about cluster.

Constructor Summary

Constructors

Constructor and Description
ClusterStateCollector()

Method Summary

Modifier and Type	Method and Description
ClusterState	collectClusterState(long epoch, SequencerMetrics sequencerMetrics) Provides cluster state
com.google.common.collect.ImmutableMap<String,Long>	collectWrongEpochs() Provides list of servers containing different epochs to this server.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterStateCollector

public ClusterStateCollector()

Method Detail

collectClusterState

public ClusterState collectClusterState(long epoch,
                                        SequencerMetrics sequencerMetrics)

Provides cluster state

Parameters:

epoch - current epoch

sequencerMetrics - sequencer metrics

Returns:

cluster state

collectWrongEpochs

public com.google.common.collect.ImmutableMap<String,Long> collectWrongEpochs()

Provides list of servers containing different epochs to this server.

Returns:

map of endpoint:epoch entries