alluxio.master

Interface PrimarySelector

All Known Implementing Classes:

AbstractPrimarySelector, AlwaysStandbyPrimarySelector, RaftPrimarySelector, UfsJournalMultiMasterPrimarySelector, UfsJournalSingleMasterPrimarySelector

public interface PrimarySelector

Interface for a class which can determine whether the local master is the primary.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	PrimarySelector.Factory Factory for creating primary selectors.

Method Summary

Modifier and Type	Method and Description
NodeState	getState()
NodeState	getStateUnsafe()
Scoped	onStateChange(java.util.function.Consumer<NodeState> listener) Registers a listener to be executed whenever the selector's state updates.
void	start(InetSocketAddress localAddress) Starts the primary selector.
void	stop() Stops the primary selector.
void	waitForState(NodeState state) Blocks until the primary selector enters the specified state.

Method Detail

start

void start(InetSocketAddress localAddress)

Starts the primary selector.

Parameters:

localAddress - the address of the local master

stop

void stop()

Stops the primary selector.

getState

NodeState getState()

Returns:

the current state

getStateUnsafe

NodeState getStateUnsafe()

Returns:

the current state without the lock acquired

onStateChange

Scoped onStateChange(java.util.function.Consumer<NodeState> listener)

Registers a listener to be executed whenever the selector's state updates. The listener will be executed synchronously in the state update thread, so it should run quickly.

Parameters:

listener - the listener

Returns:

an object which will unregister the listener when closed

waitForState

void waitForState(NodeState state)
           throws InterruptedException

Blocks until the primary selector enters the specified state.

Parameters:

state - the state to wait for

Throws:

InterruptedException