Package | Description |
---|---|
alluxio | |
alluxio.master | |
alluxio.proxy | |
alluxio.retry |
Set of utilities for working with retryable operations.
|
alluxio.worker |
Worker process and utils for working with the worker remotely.
|
Constructor and Description |
---|
AbstractClient(Subject subject,
InetSocketAddress address,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
Creates a new client base.
|
AbstractMasterClient(MasterClientConfig conf,
InetSocketAddress address,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
Creates a new master client base.
|
Constructor and Description |
---|
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier) |
Constructor and Description |
---|
ProxyHealthCheckClient(InetSocketAddress proxyAddress,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
Creates a proxy health check client.
|
Modifier and Type | Class and Description |
---|---|
class |
CountingRetry
An option which allows retrying based on maximum count.
|
class |
ExponentialBackoffRetry
Each retry will cause a sleep to happen.
|
class |
ExponentialTimeBoundedRetry
A retry policy which uses exponential backoff and a maximum duration time bound.
|
class |
SleepingRetry
A retry policy that uses thread sleeping for the delay.
|
class |
TimeBoundedRetry
Retry mechanism which performs retries until a certain period of time has elapsed.
|
class |
TimeoutRetry
A retry policy which allows retrying until a specified timeout is reached.
|
Modifier and Type | Method and Description |
---|---|
static void |
RetryUtils.retry(String action,
RetryUtils.RunnableThrowsIOException f,
RetryPolicy policy)
Retries the given method until it doesn't throw an IO exception or the retry policy expires.
|
Constructor and Description |
---|
WorkerHealthCheckClient(InetSocketAddress workerAddress,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
Creates a worker health check client.
|
Copyright © 2023. All Rights Reserved.