alluxio.master

Class MasterHealthCheckClient

java.lang.Object

alluxio.master.MasterHealthCheckClient

All Implemented Interfaces:

HealthCheckClient

public class MasterHealthCheckClient
extends Object
implements HealthCheckClient

MasterHealthCheckClient check whether Alluxio master is serving RPC requests and if the AlluxioMaster process is running in all master hosts.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MasterHealthCheckClient.Builder Builder for a MasterHealthCheckClient.
class	MasterHealthCheckClient.MasterServingHealthCheck Runnable for checking if the AlluxioMaster is serving RPCs.
static class	MasterHealthCheckClient.MasterType An enum mapping master types to fully qualified class names.
class	MasterHealthCheckClient.ProcessCheckRunnable Runnable for checking if the AlluxioMaster process are running in all the masters hosts.

Constructor Summary

Constructors

Constructor and Description
MasterHealthCheckClient(MasterHealthCheckClient.MasterType alluxioMasterType, boolean processCheck, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf) Creates a new instance of MasterHealthCheckClient.

Method Summary

Modifier and Type	Method and Description
boolean	isServing()

Methods inherited from class java.lang.Object

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

Constructor Detail

MasterHealthCheckClient

public MasterHealthCheckClient(MasterHealthCheckClient.MasterType alluxioMasterType,
                               boolean processCheck,
                               java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
                               AlluxioConfiguration alluxioConf)

Creates a new instance of MasterHealthCheckClient.

Parameters:

alluxioMasterType - the Alluxio master process type

processCheck - whether to check the AlluxioMaster process is alive

retryPolicySupplier - the policy supplier to utilize for the rpc check

alluxioConf - Alluxio configuration

Method Detail

isServing

public boolean isServing()

Specified by:

isServing in interface HealthCheckClient

Returns:

true if the service is serving requests, otherwise false. The implementation should perform retries if appropriate