RemoteIngestionRepairService (venice API)

java.lang.Object
- com.linkedin.venice.service.AbstractVeniceService
- - com.linkedin.davinci.kafka.consumer.RemoteIngestionRepairService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable
```
public class RemoteIngestionRepairService
extends AbstractVeniceService
```
Singleton class meant to keep track of subscription failures for ingestion tasks where the ingestion task needs to keep running despite cluster failures. TODO: This class could stand to be refactored into an Actor class, but it seems we're short on time just now, so we're going for old hat to start with AbstractVeniceService.

Nested Class Summary
- Nested classes/interfaces inherited from class com.linkedin.venice.service.AbstractVeniceService
  AbstractVeniceService.ServiceState

Field Summary

Fields
Modifier and Type Field Description

static int DEFAULT_REPAIR_THREAD_SLEEP_INTERVAL_SECONDS
- Fields inherited from class com.linkedin.venice.service.AbstractVeniceService
  logger, serviceState

Constructor Summary

Constructors
Constructor Description

RemoteIngestionRepairService(int repairThreadSleepInterval)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`registerRepairTask(StoreIngestionTask storeIngestionTask, java.lang.Runnable repairTask)`
`boolean`	`startInner()`
`void`	`stopInner()`
`void`	`unregisterRepairTasksForStoreIngestionTask(StoreIngestionTask storeIngestionTask)`

Methods inherited from class com.linkedin.venice.service.AbstractVeniceService
close, getName, isRunning, start, stop

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - DEFAULT_REPAIR_THREAD_SLEEP_INTERVAL_SECONDS
```
public static final int DEFAULT_REPAIR_THREAD_SLEEP_INTERVAL_SECONDS
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - RemoteIngestionRepairService
```
public RemoteIngestionRepairService(int repairThreadSleepInterval)
```
- Method Detail
  - startInner
```
public boolean startInner()
                   throws java.lang.Exception
```
    Specified by:
    
    startInner in class AbstractVeniceService
    
    Returns:
    
    true if the service is completely started, false if it is still starting asynchronously (in this case, it is the implementer's responsibility to set AbstractVeniceService.serviceState to AbstractVeniceService.ServiceState.STARTED upon completion of the async work).
    
    Throws:
    
    java.lang.Exception
  - stopInner
```
public void stopInner()
               throws java.lang.Exception
```
    Specified by:
    
    stopInner in class AbstractVeniceService
    
    Throws:
    
    java.lang.Exception
  - registerRepairTask
```
public void registerRepairTask(StoreIngestionTask storeIngestionTask,
                               java.lang.Runnable repairTask)
```
  - unregisterRepairTasksForStoreIngestionTask
```
public void unregisterRepairTasksForStoreIngestionTask(StoreIngestionTask storeIngestionTask)
```