alluxio.master

Class MasterHealthCheckClient.MasterServingHealthCheck

java.lang.Object

alluxio.common.RpcPortHealthCheckClient

alluxio.master.MasterHealthCheckClient.MasterServingHealthCheck

All Implemented Interfaces:

HealthCheckClient, Runnable

Enclosing class:

MasterHealthCheckClient

public final class MasterHealthCheckClient.MasterServingHealthCheck
extends RpcPortHealthCheckClient
implements Runnable

Runnable for checking if the AlluxioMaster is serving RPCs.

Constructor Summary

Constructors

Constructor and Description
MasterServingHealthCheck(InetSocketAddress nodeAddress, ServiceType serviceType, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf) Creates a new instance of MasterHealthCheckClient.MasterServingHealthCheck to check for an open RPC port for the given service.

Method Summary

Modifier and Type	Method and Description
void	run()
boolean	serving()

Methods inherited from class alluxio.common.RpcPortHealthCheckClient

isServing

Methods inherited from class java.lang.Object

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

Constructor Detail

MasterServingHealthCheck

public MasterServingHealthCheck(InetSocketAddress nodeAddress,
                                ServiceType serviceType,
                                java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
                                AlluxioConfiguration alluxioConf)

Creates a new instance of MasterHealthCheckClient.MasterServingHealthCheck to check for an open RPC port for the given service.

Parameters:

nodeAddress - the address of the node to connect to

serviceType - the gRPC service type

retryPolicySupplier - a retry policy supplier

alluxioConf - Alluxio configuration

Method Detail

run

public void run()

Specified by:

run in interface Runnable

serving

public boolean serving()

Returns:

whether or we were able to ping the service