alluxio.common

Class RpcPortHealthCheckClient

java.lang.Object

alluxio.common.RpcPortHealthCheckClient

All Implemented Interfaces:

HealthCheckClient

Direct Known Subclasses:

JobMasterRpcHealthCheckClient, JobWorkerHealthCheckClient, MasterHealthCheckClient.MasterServingHealthCheck, WorkerHealthCheckClient

public class RpcPortHealthCheckClient
extends Object
implements HealthCheckClient

RpcPortHealthCheckClient check if worker is serving RPC.

Constructor Summary

Constructors

Constructor and Description
RpcPortHealthCheckClient(InetSocketAddress nodeAddress, ServiceType serviceType, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf) Creates a worker health check client.

Method Summary

Modifier and Type	Method and Description
protected AlluxioConfiguration	getConfiguration()
protected InetSocketAddress	getNodeAddress()
protected java.util.function.Supplier<RetryPolicy>	getRetryPolicySupplier()
protected ServiceType	getServiceType()
protected UserState	getUserState()
boolean	isServing()

Methods inherited from class java.lang.Object

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

Constructor Detail

RpcPortHealthCheckClient

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

Creates a worker health check client.

Parameters:

nodeAddress - The potential node address

serviceType - The type of service

retryPolicySupplier - the retry policy supplier

alluxioConf - Alluxio configuration

Method Detail

getRetryPolicySupplier

protected java.util.function.Supplier<RetryPolicy> getRetryPolicySupplier()

getNodeAddress

protected InetSocketAddress getNodeAddress()

getServiceType

protected ServiceType getServiceType()

getConfiguration

protected AlluxioConfiguration getConfiguration()

getUserState

protected UserState getUserState()

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