Interface | Description |
---|---|
AsyncServiceSchedulerResultsReceiver |
Interface for receiving results from Asynchronous Service Schedulers.
|
KafkaConnectionPool |
Interface for KafkaConnectionPools
|
ObjectStorePool |
ObjectStorePool interface for handling of ObjectStoreRequests.
|
Class | Description |
---|---|
AbstractAsyncServiceScheduler |
Abstract asynchronous service scheduler for Restore interaction with external services.
|
AsyncTaskScheduler |
AsyncTaskScheduler for scheduling compute / local I/O intensive tasks.
|
CompletableFutureRetryer |
Build retry logic for a
CompletableFuture |
Constants | |
CopyObjectOperator | |
DryrunAsyncTaskScheduler | |
DryrunKafkaConnectionPoolImpl | |
DryrunObjectStorePoolImpl | |
FtpsFetcher |
It is a wrapper class for the method of calling Kafka API to download ftps file.
|
KafkaConnectionPoolImpl |
Connection pool for scheduling async restore-related requests to Kafka brokers
|
KafkaManager |
KafkaManager for scheduling and processing asynchronous calls to Kafka REST API for restore task.
|
ListVersionsOperator |
A wrapper to send list object request to object store asynchronously
|
ObjectStoreManager |
ObjectStoreManager for scheduling and processing calls to ObjectStore APIs in an asynchronous manner.
|
ObjectStorePoolImpl |
Connection pool for execution
ObjectStoreRequest s that involve communicating wih Object Store. |
PartitionLogRangeValidator |
It is a wrapper class for the method of calling Kafka API to fetch Partition Status.
|
PartitionStatusFetcher |
It is a wrapper class for the method of calling Kafka API to fetch Partition Status.
|
RestoreObjectMultipleResponseHandler |
RestoreObjectsInStoreRequest is a "complex" request (see
MultipleResponseHandler for explain what
a complex request means). |
S3ObjectStorePool | |
SchedulerUtil | |
ThreadPoolMonitor |
Enum | Description |
---|---|
AbstractAsyncServiceScheduler.AsyncServiceSchedulerStatus |
Possible statuses of the AsyncServiceScheduler.
|
Exception | Description |
---|---|
PermanentException | |
RetryableException |