alluxio.master.journal.raft

Class RaftPrimarySelector

java.lang.Object

alluxio.master.AbstractPrimarySelector

alluxio.master.journal.raft.RaftPrimarySelector

All Implemented Interfaces:

PrimarySelector

@ThreadSafe
public class RaftPrimarySelector
extends AbstractPrimarySelector

A primary selector backed by a Raft consensus cluster.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.PrimarySelector

PrimarySelector.Factory, PrimarySelector.State

Constructor Summary

Constructors

Constructor and Description
RaftPrimarySelector()

Method Summary

Modifier and Type	Method and Description
void	notifyStateChanged(PrimarySelector.State state) Notifies leadership state changed.
void	start(InetSocketAddress address) Starts the primary selector.
void	stop() Stops the primary selector.

Methods inherited from class alluxio.master.AbstractPrimarySelector

getState, onStateChange, setState, waitForState

Methods inherited from class java.lang.Object

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

Constructor Detail

RaftPrimarySelector

public RaftPrimarySelector()

Method Detail

notifyStateChanged

public void notifyStateChanged(PrimarySelector.State state)

Notifies leadership state changed.

Parameters:

state - the leadership state

start

public void start(InetSocketAddress address)
           throws IOException

Description copied from interface: PrimarySelector

Starts the primary selector.

Parameters:

address - the address of the local master

Throws:

IOException

stop

public void stop()
          throws IOException

Description copied from interface: PrimarySelector

Stops the primary selector.

Throws:

IOException