alluxio.master.journal

Interface JournalMaster

All Superinterfaces:

Checkpointed, Journaled, JournalEntryIterable, Master, Server<Boolean>

All Known Implementing Classes:

DefaultJournalMaster

public interface JournalMaster
extends Master

Interface for journal master implementations.

Method Summary

Modifier and Type	Method and Description
GetNodeStatePResponse	getNodeState() Gets the node state.
GetQuorumInfoPResponse	getQuorumInfo() Quorum information for participating servers in journal.
GetTransferLeaderMessagePResponse	getTransferLeaderMessage(String transferId) Gets exception messages thrown when transferring the leader.
void	removeQuorumServer(NetAddress serverAddress) Removes a server from journal quorum.
void	resetPriorities() Resets RaftPeer priorities.
String	transferLeadership(NetAddress newLeaderAddress) Changes the leading master of the journal quorum.

Methods inherited from interface alluxio.master.Master

createJournalContext, getMasterContext, getStandbyServices

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

Methods inherited from interface alluxio.master.journal.checkpoint.Checkpointed

getCheckpointName

Methods inherited from interface alluxio.master.journal.JournalEntryIterable

getJournalEntryIterator

Methods inherited from interface alluxio.Server

close, getDependencies, getName, getServices, start, stop

Method Detail

getQuorumInfo

GetQuorumInfoPResponse getQuorumInfo()
                              throws IOException

Quorum information for participating servers in journal. This method is supported only for JournalType.EMBEDDED journal.

Returns:

the quorum info

Throws:

IOException - if error occurs while performing the operation

removeQuorumServer

void removeQuorumServer(NetAddress serverAddress)
                 throws IOException

Removes a server from journal quorum. This method is supported only for JournalType.EMBEDDED journal.

Parameters:

serverAddress - server address to remove from quorum

Throws:

IOException - if error occurs while performing the operation

transferLeadership

String transferLeadership(NetAddress newLeaderAddress)

Changes the leading master of the journal quorum. This method is supported only for JournalType.EMBEDDED journal.

Parameters:

newLeaderAddress - server address to remove from quorum

Returns:

the guid of transfer leader command

resetPriorities

void resetPriorities()
              throws IOException

Resets RaftPeer priorities.

Throws:

IOException - if error occurs while performing the operation

getTransferLeaderMessage

GetTransferLeaderMessagePResponse getTransferLeaderMessage(String transferId)

Gets exception messages thrown when transferring the leader.

Parameters:

transferId - the guid of transferLeader command

Returns:

exception message

getNodeState

GetNodeStatePResponse getNodeState()

Gets the node state. This endpoint is available for both UFS and embedded journals. If HA mode is turn off, the node state will always be returned as PRIMARY.

Returns:

whether the node is a primary or standby