Package org.apache.cassandra.repair.autorepair

Class AutoRepair

java.lang.Object

org.apache.cassandra.repair.autorepair.AutoRepair

public class AutoRepair
extends Object

AutoRepair scheduler responsible for running different types of repairs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AutoRepair.RepairProgressListener

Field Summary

Fields

Modifier and Type	Field	Description
static AutoRepair	instance
boolean	isSetupDone
boolean	isShutDown
protected Map<AutoRepairConfig.RepairType,ScheduledExecutorPlus>	repairExecutors
protected Map<AutoRepairConfig.RepairType,ScheduledExecutorPlus>	repairRunnableExecutors
Map<AutoRepairConfig.RepairType,AutoRepairState>	repairStates
protected static Consumer<List<String>>	shuffleFunc
static DurationSpec.IntSecondsBound	SLEEP_IF_REPAIR_FINISHES_QUICKLY
protected static BiConsumer<Long,TimeUnit>	sleepFunc
protected static Supplier<Long>	timeFunc

Method Summary

Modifier and Type	Method	Description
long	currentTimeMs()
Map<AutoRepairConfig.RepairType,ScheduledExecutorPlus>	getRepairExecutors()
Map<AutoRepairConfig.RepairType,ScheduledExecutorPlus>	getRepairRunnableExecutors()
AutoRepairState	getRepairState(AutoRepairConfig.RepairType repairType)
void	repair(AutoRepairConfig.RepairType repairType)
void	setup()
void	shutdownBlocking()

Methods inherited from class java.lang.Object

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

Field Details

timeFunc

protected static Supplier<Long> timeFunc

SLEEP_IF_REPAIR_FINISHES_QUICKLY

public static DurationSpec.IntSecondsBound SLEEP_IF_REPAIR_FINISHES_QUICKLY

repairStates

public Map<AutoRepairConfig.RepairType,AutoRepairState> repairStates

repairExecutors

protected Map<AutoRepairConfig.RepairType,ScheduledExecutorPlus> repairExecutors

repairRunnableExecutors

protected Map<AutoRepairConfig.RepairType,ScheduledExecutorPlus> repairRunnableExecutors

shuffleFunc

protected static Consumer<List<String>> shuffleFunc

sleepFunc

protected static BiConsumer<Long,TimeUnit> sleepFunc

isSetupDone

public boolean isSetupDone

instance

public static AutoRepair instance

isShutDown

public volatile boolean isShutDown

Method Details

setup

public void setup()

currentTimeMs

public long currentTimeMs()

Returns:

The current observed system time in ms.

repair

public void repair(AutoRepairConfig.RepairType repairType)

getRepairState

public AutoRepairState getRepairState(AutoRepairConfig.RepairType repairType)

shutdownBlocking

public void shutdownBlocking()
                      throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

getRepairExecutors

public Map<AutoRepairConfig.RepairType,ScheduledExecutorPlus> getRepairExecutors()

getRepairRunnableExecutors

public Map<AutoRepairConfig.RepairType,ScheduledExecutorPlus> getRepairRunnableExecutors()