alluxio.worker.job

Class JobWorkerHealthCheckClient

java.lang.Object

alluxio.common.RpcPortHealthCheckClient

alluxio.worker.job.JobWorkerHealthCheckClient

All Implemented Interfaces:

HealthCheckClient

public class JobWorkerHealthCheckClient
extends RpcPortHealthCheckClient

JobWorkerHealthCheckClient check if worker is serving RPC.

Constructor Summary

Constructors

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

Method Summary

Methods inherited from class alluxio.common.RpcPortHealthCheckClient

getConfiguration, getNodeAddress, getRetryPolicySupplier, getServiceType, getUserState, isServing

Methods inherited from class java.lang.Object

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

Constructor Detail

JobWorkerHealthCheckClient

public JobWorkerHealthCheckClient(InetSocketAddress jobWorkerAddress,
                                  java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
                                  AlluxioConfiguration alluxioConf)

Creates a worker health check client.

Parameters:

jobWorkerAddress - The potential job_worker address

retryPolicySupplier - the retry policy supplier

alluxioConf - Alluxio configuration