alluxio.master

Interface PrimarySelector

All Known Implementing Classes:

AbstractPrimarySelector, PrimarySelectorClient, RaftPrimarySelector

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.
static class	PrimarySelector.State The state for the primary selector.

Method Summary

Modifier and Type	Method and Description
PrimarySelector.State	getState()
Scoped	onStateChange(java.util.function.Consumer<PrimarySelector.State> 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(PrimarySelector.State state) Blocks until the primary selector enters the specified state.

Method Detail

start

void start(InetSocketAddress localAddress)
    throws IOException

Starts the primary selector.

Parameters:

localAddress - the address of the local master

Throws:

IOException

stop

void stop()
   throws IOException

Stops the primary selector.

Throws:

IOException

getState

PrimarySelector.State getState()

Returns:

the current state

onStateChange

Scoped onStateChange(java.util.function.Consumer<PrimarySelector.State> 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(PrimarySelector.State state)
           throws InterruptedException

Blocks until the primary selector enters the specified state.

Parameters:

state - the state to wait for

Throws:

InterruptedException