alluxio.proxy

Class ProxyMasterSync

java.lang.Object

alluxio.proxy.ProxyMasterSync

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

@NotThreadSafe
public final class ProxyMasterSync
extends Object
implements HeartbeatExecutor

The Proxy will maintain a stateless heartbeat with the primary master. This enables the admin to list all living Proxy instances in the cluster.

Constructor Summary

Constructors

Constructor and Description
ProxyMasterSync(Address address, MasterClientContext context, long startTimeMs) Creates a new instance of ProxyMasterSync.

Method Summary

Modifier and Type	Method and Description
void	close() Cleans up any resources used by the heartbeat executor.
void	heartbeat(long timeLimitMs) Heartbeats to the primary master node.

Methods inherited from class java.lang.Object

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

Constructor Detail

ProxyMasterSync

public ProxyMasterSync(Address address,
                       MasterClientContext context,
                       long startTimeMs)

Creates a new instance of ProxyMasterSync.

Parameters:

address - the proxy address

context - the communication context

startTimeMs - start time of this instance

Method Detail

heartbeat

public void heartbeat(long timeLimitMs)

Heartbeats to the primary master node.

Specified by:

heartbeat in interface HeartbeatExecutor

Parameters:

timeLimitMs - time limit in milliseconds this heartbeat should not exceed when running

close

public void close()

Description copied from interface: HeartbeatExecutor

Cleans up any resources used by the heartbeat executor.

Specified by:

close in interface HeartbeatExecutor

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable