alluxio.hub.manager.util

Class HubCluster

java.lang.Object

alluxio.hub.manager.util.HubCluster

All Implemented Interfaces:

ProtoConverter<HubCluster>, AutoCloseable

@ThreadSafe
public class HubCluster
extends Object
implements ProtoConverter<HubCluster>, AutoCloseable

A class representing a set of Hub Agent nodes registered with the manager.

Constructor Summary

Constructors

Constructor and Description
HubCluster(ScheduledExecutorService svc, long lostThreshold, long deleteThreshold) Creates a new instance of HubCluster.
HubCluster(ScheduledExecutorService svc, long lostThreshold, long deleteThreshold, AlluxioCluster alluxioCluster) Creates a new instance of HubCluster.

Method Summary

Modifier and Type	Method and Description
void	add(HubNodeAddress addr) Add a new node to the cluster.
Set<HubNodeAddress>	allNodes()
void	close()
<T> Map<HubNodeAddress,T>	exec(Set<HubNodeAddress> hosts, AlluxioConfiguration conf, java.util.function.Function<AgentManagerServiceGrpc.AgentManagerServiceBlockingStub,T> action, ExecutorService svc) Execute an RPC action on all nodes in the cluster.
AlluxioCluster	getAlluxioCluster() Get alluxio cluster.
void	heartbeat(HubNodeAddress addr) heartbeats to update the state of the node with the given address.
Set<String>	hosts()
Set<HubNodeAddress>	nodesFromAlluxio(AlluxioCluster cluster, AlluxioNodeType type) Returns a set of Hub nodes corresponding to the given AlluxioNodeType from an AlluxioCluster.
boolean	remove(HubNodeAddress addr) Removes a node from the cluster.
int	size()
HubCluster	toProto() Converts an objects representation into a protobuf type.

Methods inherited from class java.lang.Object

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

Constructor Detail

HubCluster

public HubCluster(ScheduledExecutorService svc,
                  long lostThreshold,
                  long deleteThreshold)

Creates a new instance of HubCluster.

Parameters:

svc - the executor service used to run event handlers

lostThreshold - the amount of time before an agent should be considered HubNodeState.LOST

deleteThreshold - the amount fo time before an agent should be removed from the cluster

HubCluster

public HubCluster(ScheduledExecutorService svc,
                  long lostThreshold,
                  long deleteThreshold,
                  AlluxioCluster alluxioCluster)

Creates a new instance of HubCluster.

Parameters:

svc - the executor service used to run event handlers

lostThreshold - the amount of time before an agent should be considered HubNodeState.LOST

deleteThreshold - the amount fo time before an agent should be removed from the cluster

alluxioCluster - the alluxio cluster that the hub cluster is managing

Method Detail

add

public void add(HubNodeAddress addr)

Add a new node to the cluster.

Parameters:

addr - the given address

Throws:

IllegalArgumentException - when either the hostname or port do not exist

heartbeat

public void heartbeat(HubNodeAddress addr)

heartbeats to update the state of the node with the given address.

Parameters:

addr - the address to heartbeat

remove

public boolean remove(HubNodeAddress addr)

Removes a node from the cluster.

Parameters:

addr - the node address to remove

Returns:

true if the host was removed, false otherwise

size

public int size()

Returns:

the number of registered nodes

hosts

public Set<String> hosts()

Returns:

a set of all hosts in the cluster

exec

public <T> Map<HubNodeAddress,T> exec(Set<HubNodeAddress> hosts,
                                      AlluxioConfiguration conf,
                                      java.util.function.Function<AgentManagerServiceGrpc.AgentManagerServiceBlockingStub,T> action,
                                      ExecutorService svc)
                               throws RuntimeException

Execute an RPC action on all nodes in the cluster.

Type Parameters:

T - the type of response from the RPC function

Parameters:

hosts - the hosts to execute on

conf - alluxio configuration

action - the client action to perform

svc - an executor service to run the RPCs in parallel

Returns:

a map of the hosts and their respective responses from the action argument

Throws:

RuntimeException - when the RPC client fail to be created or any of the RPCs fail

nodesFromAlluxio

public Set<HubNodeAddress> nodesFromAlluxio(AlluxioCluster cluster,
                                            AlluxioNodeType type)

Returns a set of Hub nodes corresponding to the given AlluxioNodeType from an AlluxioCluster.

Parameters:

cluster - the alluxio cluster to query from

type - the type of Alluxio node to query for

Returns:

a set of Hub nodes co-located with Alluxio processes of the given type

allNodes

public Set<HubNodeAddress> allNodes()

Returns:

a set containing all live hub nodes

getAlluxioCluster

public AlluxioCluster getAlluxioCluster()

Get alluxio cluster.

Returns:

alluxio cluster

toProto

public HubCluster toProto()

Description copied from interface: ProtoConverter

Converts an objects representation into a protobuf type.

Specified by:

toProto in interface ProtoConverter<HubCluster>

Returns:

the object as a proto representation

close

public void close()

Specified by:

close in interface AutoCloseable