alluxio.master.backup

Class BackupHandshakeMessage

java.lang.Object

alluxio.master.backup.BackupHandshakeMessage

All Implemented Interfaces:

io.atomix.catalyst.serializer.CatalystSerializable

public class BackupHandshakeMessage
extends Object
implements io.atomix.catalyst.serializer.CatalystSerializable

The backup message used for introducing backup-worker to leader.

Constructor Summary

Constructors

Constructor and Description
BackupHandshakeMessage() Empty constructor as per deserialization requirement.
BackupHandshakeMessage(String hostname) Creates a handshake message.

Method Summary

Modifier and Type	Method and Description
String	getBackupWorkerHostname()
GrpcMessagingConnection	getConnection()
void	readObject(io.atomix.catalyst.buffer.BufferInput<?> bufferInput, io.atomix.catalyst.serializer.Serializer serializer)
void	setConnection(GrpcMessagingConnection connection)
String	toString()
void	writeObject(io.atomix.catalyst.buffer.BufferOutput<?> bufferOutput, io.atomix.catalyst.serializer.Serializer serializer)

Methods inherited from class java.lang.Object

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

Constructor Detail

BackupHandshakeMessage

public BackupHandshakeMessage()

Empty constructor as per deserialization requirement.

BackupHandshakeMessage

public BackupHandshakeMessage(String hostname)

Creates a handshake message.

Parameters:

hostname - backup-worker hostname

Method Detail

getBackupWorkerHostname

public String getBackupWorkerHostname()

Returns:

the hostname for the backup-worker

setConnection

public void setConnection(GrpcMessagingConnection connection)

Parameters:

connection - connection from which this message is coming from

getConnection

public GrpcMessagingConnection getConnection()

Returns:

connection from which this message is coming from

writeObject

public void writeObject(io.atomix.catalyst.buffer.BufferOutput<?> bufferOutput,
                        io.atomix.catalyst.serializer.Serializer serializer)

Specified by:

writeObject in interface io.atomix.catalyst.serializer.CatalystSerializable

readObject

public void readObject(io.atomix.catalyst.buffer.BufferInput<?> bufferInput,
                       io.atomix.catalyst.serializer.Serializer serializer)

Specified by:

readObject in interface io.atomix.catalyst.serializer.CatalystSerializable

toString

public String toString()

Overrides:

toString in class Object