Package com.linkedin.venice.controller

Class DegradedModeRecoveryService

java.lang.Object

com.linkedin.venice.controller.DegradedModeRecoveryService

All Implemented Interfaces:

Closeable, AutoCloseable

public class DegradedModeRecoveryService
extends Object
implements Closeable

Orchestrates bulk data recovery for PARTIALLY_ONLINE stores when a degraded DC is unmarked. Uses prepare → poll readiness → initiate flow with bounded concurrency and retry.

Constructor Summary

Constructors

Constructor	Description
DegradedModeRecoveryService(Admin admin, DegradedModeStats stats)
DegradedModeRecoveryService(Admin admin, DegradedModeStats stats, int threadPoolSize, VeniceControllerMultiClusterConfig multiClusterConfigs)

Method Summary

Modifier and Type	Method	Description
void	close()
RecoveryProgress	getRecoveryProgress(String clusterName, String datacenterName)
void	startDegradedDcMonitor(Set<String> clusterNames)	Start the periodic monitor that emits duration metrics for degraded DCs.
void	triggerRecovery(String clusterName, String datacenterName)	Trigger async recovery for all PARTIALLY_ONLINE stores in the given datacenter.

Methods inherited from class java.lang.Object

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

Constructor Details

DegradedModeRecoveryService

public DegradedModeRecoveryService(Admin admin,
 DegradedModeStats stats)

DegradedModeRecoveryService

public DegradedModeRecoveryService(Admin admin,
 DegradedModeStats stats,
 int threadPoolSize,
 VeniceControllerMultiClusterConfig multiClusterConfigs)

Method Details

startDegradedDcMonitor

public void startDegradedDcMonitor(Set<String> clusterNames)

Start the periodic monitor that emits duration metrics for degraded DCs.

triggerRecovery

public void triggerRecovery(String clusterName,
 String datacenterName)

Trigger async recovery for all PARTIALLY_ONLINE stores in the given datacenter.

getRecoveryProgress

public RecoveryProgress getRecoveryProgress(String clusterName,
 String datacenterName)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable