alluxio.master.journal.raft

Class RaftJournalConfiguration

java.lang.Object

alluxio.master.journal.raft.RaftJournalConfiguration

public class RaftJournalConfiguration
extends Object

Configuration for the Raft journal system.

Constructor Summary

Constructors

Constructor and Description
RaftJournalConfiguration()

Method Summary

Modifier and Type	Method and Description
static RaftJournalConfiguration	defaults(NetworkAddressUtils.ServiceType serviceType)
List<InetSocketAddress>	getClusterAddresses()
InetSocketAddress	getLocalAddress()
Integer	getMaxConcurrencyPoolSize()
long	getMaxElectionTimeoutMs()
long	getMaxLogSize()
long	getMinElectionTimeoutMs()
File	getPath()
InetSocketAddress	getProxyAddress()
RaftJournalConfiguration	setClusterAddresses(List<InetSocketAddress> clusterAddresses)
RaftJournalConfiguration	setElectionMaxTimeoutMs(long maxElectionTimeoutMs)
RaftJournalConfiguration	setElectionMinTimeoutMs(long minElectionTimeoutMs)
RaftJournalConfiguration	setLocalAddress(InetSocketAddress localAddress)
RaftJournalConfiguration	setMaxConcurrencyPoolSize(Integer maxConcurrencyPoolSize)
RaftJournalConfiguration	setMaxLogSize(long maxLogSize)
RaftJournalConfiguration	setPath(File path)
void	validate() Validates the configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

RaftJournalConfiguration

public RaftJournalConfiguration()

Method Detail

defaults

public static RaftJournalConfiguration defaults(NetworkAddressUtils.ServiceType serviceType)

Parameters:

serviceType - either master raft service or job master raft service

Returns:

default configuration for the specified service type

validate

public void validate()

Validates the configuration.

getClusterAddresses

public List<InetSocketAddress> getClusterAddresses()

Returns:

addresses of all nodes in the Raft cluster

getMinElectionTimeoutMs

public long getMinElectionTimeoutMs()

Returns:

min election timeout

getMaxElectionTimeoutMs

public long getMaxElectionTimeoutMs()

Returns:

max election timeout

getLocalAddress

public InetSocketAddress getLocalAddress()

Returns:

address of this Raft cluster node

getProxyAddress

public InetSocketAddress getProxyAddress()

Returns:

proxy address of this Raft cluster node

getMaxLogSize

public long getMaxLogSize()

Returns:

max log file size

getPath

public File getPath()

Returns:

where to store journal logs

setClusterAddresses

public RaftJournalConfiguration setClusterAddresses(List<InetSocketAddress> clusterAddresses)

Parameters:

clusterAddresses - addresses of all nodes in the Raft cluster

Returns:

the updated configuration

setElectionMinTimeoutMs

public RaftJournalConfiguration setElectionMinTimeoutMs(long minElectionTimeoutMs)

Parameters:

minElectionTimeoutMs - min election timeout

Returns:

the updated configuration

setElectionMaxTimeoutMs

public RaftJournalConfiguration setElectionMaxTimeoutMs(long maxElectionTimeoutMs)

Parameters:

maxElectionTimeoutMs - max election timeout

Returns:

the updated configuration

setLocalAddress

public RaftJournalConfiguration setLocalAddress(InetSocketAddress localAddress)

Parameters:

localAddress - address of this Raft cluster node

Returns:

the updated configuration

setMaxLogSize

public RaftJournalConfiguration setMaxLogSize(long maxLogSize)

Parameters:

maxLogSize - maximum log file size

Returns:

the updated configuration

setPath

public RaftJournalConfiguration setPath(File path)

Parameters:

path - where to store journal logs

Returns:

the updated configuration

getMaxConcurrencyPoolSize

public Integer getMaxConcurrencyPoolSize()

Returns:

the maxConcurrencyPoolSize

setMaxConcurrencyPoolSize

public RaftJournalConfiguration setMaxConcurrencyPoolSize(Integer maxConcurrencyPoolSize)

Parameters:

maxConcurrencyPoolSize - max thread size for notifyTermIndexUpdated method

Returns:

the updated configuration