alluxio.master.meta.checkconf

Class ServerConfigurationStore

java.lang.Object

alluxio.master.meta.checkconf.ServerConfigurationStore

@ThreadSafe
public class ServerConfigurationStore
extends java.lang.Object

This class is responsible for recording server-side configuration.

Constructor Summary

Constructors

Constructor and Description
ServerConfigurationStore() Constructs a new ServerConfigurationStore.

Method Summary

Modifier and Type	Method and Description
java.util.Map<Address,java.util.List<ConfigRecord>>	getConfMap()
java.util.List<Address>	getLiveNodeAddresses()
void	handleNodeLost(Address address) Updates configuration when a live node becomes lost.
void	lostNodeFound(Address address) Updates configuration when a lost node is found.
void	registerChangeListener(java.lang.Runnable function) Registers callback functions to use when this store has any changes.
void	registerNewConf(Address address, java.util.List<ConfigProperty> configList) Registers new configuration information.
void	reset() Resets the default ServerConfigurationStore.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerConfigurationStore

public ServerConfigurationStore()

Constructs a new ServerConfigurationStore.

Method Detail

reset

public void reset()

Resets the default ServerConfigurationStore.

registerNewConf

public void registerNewConf(Address address,
                            java.util.List<ConfigProperty> configList)

Registers new configuration information.

Parameters:

address - the node address

configList - the configuration of this node

handleNodeLost

public void handleNodeLost(Address address)

Updates configuration when a live node becomes lost.

Parameters:

address - the node address

lostNodeFound

public void lostNodeFound(Address address)

Updates configuration when a lost node is found.

Parameters:

address - the node address

getConfMap

public java.util.Map<Address,java.util.List<ConfigRecord>> getConfMap()

Returns:

a copy of the configuration map of live nodes

getLiveNodeAddresses

public java.util.List<Address> getLiveNodeAddresses()

Returns:

the addresses of live nodes

registerChangeListener

public void registerChangeListener(java.lang.Runnable function)

Registers callback functions to use when this store has any changes.

Parameters:

function - the function to register