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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RaftJournalConfiguration.StorageLevel Enum corresponding to io.atomix.copycat.server.storage.StorageLevel.

Constructor Summary

Constructors

Constructor and Description
RaftJournalConfiguration()

Method Summary

Modifier and Type	Method and Description
static RaftJournalConfiguration	defaults(NetworkAddressUtils.ServiceType serviceType)
List<InetSocketAddress>	getClusterAddresses()
long	getElectionTimeoutMs()
long	getHeartbeatIntervalMs()
InetSocketAddress	getLocalAddress()
long	getMaxLogSize()
File	getPath()
InetSocketAddress	getProxyAddress()
RaftJournalConfiguration.StorageLevel	getStorageLevel()
RaftJournalConfiguration	setClusterAddresses(List<InetSocketAddress> clusterAddresses)
RaftJournalConfiguration	setElectionTimeoutMs(long electionTimeoutMs)
RaftJournalConfiguration	setHeartbeatIntervalMs(long heartbeatIntervalMs)
RaftJournalConfiguration	setLocalAddress(InetSocketAddress localAddress)
RaftJournalConfiguration	setMaxLogSize(long maxLogSize)
RaftJournalConfiguration	setPath(File path)
RaftJournalConfiguration	setStorageLevel(RaftJournalConfiguration.StorageLevel storageLevel)
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

getElectionTimeoutMs

public long getElectionTimeoutMs()

Returns:

election timeout

getHeartbeatIntervalMs

public long getHeartbeatIntervalMs()

Returns:

heartbeat interval

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

getStorageLevel

public RaftJournalConfiguration.StorageLevel getStorageLevel()

Returns:

storage level

setClusterAddresses

public RaftJournalConfiguration setClusterAddresses(List<InetSocketAddress> clusterAddresses)

Parameters:

clusterAddresses - addresses of all nodes in the Raft cluster

Returns:

the updated configuration

setElectionTimeoutMs

public RaftJournalConfiguration setElectionTimeoutMs(long electionTimeoutMs)

Parameters:

electionTimeoutMs - election timeout

Returns:

the updated configuration

setHeartbeatIntervalMs

public RaftJournalConfiguration setHeartbeatIntervalMs(long heartbeatIntervalMs)

Parameters:

heartbeatIntervalMs - heartbeat interval

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

setStorageLevel

public RaftJournalConfiguration setStorageLevel(RaftJournalConfiguration.StorageLevel storageLevel)

Parameters:

storageLevel - storage level

Returns:

the updated configuration