Package org.apache.cassandra.service

Class AutoRepairService

java.lang.Object

org.apache.cassandra.service.AutoRepairService

All Implemented Interfaces:

AutoRepairServiceMBean

public class AutoRepairService
extends Object
implements AutoRepairServiceMBean

Implement all the MBeans for AutoRepair.

Field Summary

Fields

Modifier and Type	Field	Description
protected AutoRepairConfig	config
static final AutoRepairService	instance
static final String	MBEAN_NAME

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AutoRepairService()

Method Summary

Modifier and Type	Method	Description
void	checkCanRun(String repairType)
void	checkCanRun(AutoRepairConfig.RepairType repairType)
AutoRepairConfig	getAutoRepairConfig()
String	getAutoRepairConfiguration()
Set<String>	getOnGoingRepairHostIds(String repairType)
boolean	isAutoRepairDisabled()
void	setAllowParallelReplicaRepair(String repairType, boolean enabled)
void	setAllowParallelReplicaRepairAcrossSchedules(String repairType, boolean enabled)
void	setAutoRepairEnabled(String repairType, boolean enabled)
void	setAutoRepairHistoryClearDeleteHostsBufferDuration(String duration)
void	setAutoRepairMaxRetriesCount(String repairType, int retries)
void	setAutoRepairMinRepairTaskDuration(String duration)
void	setAutoRepairRetryBackoff(String repairType, String interval)
void	setAutoRepairTableMaxRepairTime(String repairType, String autoRepairTableMaxRepairTime)
void	setAutoRepairTokenRangeSplitterParameter(String repairType, String key, String value)
void	setForceRepairForHosts(String repairType, String commaSeparatedHostSet)
void	setIgnoreDCs(String repairType, Set<String> ignoreDCs)
void	setMixedMajorVersionRepairEnabled(boolean enabled)
void	setMVRepairEnabled(String repairType, boolean enabled)
void	setParallelRepairCount(String repairType, int count)
void	setParallelRepairPercentage(String repairType, int percentage)
void	setPrimaryTokenRangeOnly(String repairType, boolean primaryTokenRangeOnly)
void	setRepairByKeyspace(String repairType, boolean repairByKeyspace)
void	setRepairMinInterval(String repairType, String minRepairInterval)
void	setRepairPriorityForHosts(String repairType, String commaSeparatedHostSet)
void	setRepairSessionTimeout(String repairType, String timeout)
void	setRepairSSTableCountHigherThreshold(String repairType, int sstableHigherThreshold)
void	setRepairThreads(String repairType, int repairThreads)
static void	setup()
void	startScheduler()

Methods inherited from class java.lang.Object

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

Field Details

MBEAN_NAME

public static final String MBEAN_NAME

See Also:

• Constant Field Values

config

protected AutoRepairConfig config

instance

public static final AutoRepairService instance

Constructor Details

AutoRepairService

protected AutoRepairService()

Method Details

setup

public static void setup()

checkCanRun

public void checkCanRun(String repairType)

checkCanRun

public void checkCanRun(AutoRepairConfig.RepairType repairType)

getAutoRepairConfig

public AutoRepairConfig getAutoRepairConfig()

isAutoRepairDisabled

public boolean isAutoRepairDisabled()

Specified by:

isAutoRepairDisabled in interface AutoRepairServiceMBean

getAutoRepairConfiguration

public String getAutoRepairConfiguration()

Specified by:

getAutoRepairConfiguration in interface AutoRepairServiceMBean

setAutoRepairEnabled

public void setAutoRepairEnabled(String repairType,
 boolean enabled)

Specified by:

setAutoRepairEnabled in interface AutoRepairServiceMBean

setRepairThreads

public void setRepairThreads(String repairType,
 int repairThreads)

Specified by:

setRepairThreads in interface AutoRepairServiceMBean

setRepairPriorityForHosts

public void setRepairPriorityForHosts(String repairType,
 String commaSeparatedHostSet)

Specified by:

setRepairPriorityForHosts in interface AutoRepairServiceMBean

setForceRepairForHosts

public void setForceRepairForHosts(String repairType,
 String commaSeparatedHostSet)

Specified by:

setForceRepairForHosts in interface AutoRepairServiceMBean

setRepairMinInterval

public void setRepairMinInterval(String repairType,
 String minRepairInterval)

Specified by:

setRepairMinInterval in interface AutoRepairServiceMBean

startScheduler

public void startScheduler()

Specified by:

startScheduler in interface AutoRepairServiceMBean

setAutoRepairHistoryClearDeleteHostsBufferDuration

public void setAutoRepairHistoryClearDeleteHostsBufferDuration(String duration)

Specified by:

setAutoRepairHistoryClearDeleteHostsBufferDuration in interface AutoRepairServiceMBean

setAutoRepairMinRepairTaskDuration

public void setAutoRepairMinRepairTaskDuration(String duration)

Specified by:

setAutoRepairMinRepairTaskDuration in interface AutoRepairServiceMBean

setRepairSSTableCountHigherThreshold

public void setRepairSSTableCountHigherThreshold(String repairType,
 int sstableHigherThreshold)

Specified by:

setRepairSSTableCountHigherThreshold in interface AutoRepairServiceMBean

setAutoRepairTableMaxRepairTime

public void setAutoRepairTableMaxRepairTime(String repairType,
 String autoRepairTableMaxRepairTime)

Specified by:

setAutoRepairTableMaxRepairTime in interface AutoRepairServiceMBean

setIgnoreDCs

public void setIgnoreDCs(String repairType,
 Set<String> ignoreDCs)

Specified by:

setIgnoreDCs in interface AutoRepairServiceMBean

setPrimaryTokenRangeOnly

public void setPrimaryTokenRangeOnly(String repairType,
 boolean primaryTokenRangeOnly)

Specified by:

setPrimaryTokenRangeOnly in interface AutoRepairServiceMBean

setParallelRepairPercentage

public void setParallelRepairPercentage(String repairType,
 int percentage)

Specified by:

setParallelRepairPercentage in interface AutoRepairServiceMBean

setParallelRepairCount

public void setParallelRepairCount(String repairType,
 int count)

Specified by:

setParallelRepairCount in interface AutoRepairServiceMBean

setAllowParallelReplicaRepair

public void setAllowParallelReplicaRepair(String repairType,
 boolean enabled)

Specified by:

setAllowParallelReplicaRepair in interface AutoRepairServiceMBean

setAllowParallelReplicaRepairAcrossSchedules

public void setAllowParallelReplicaRepairAcrossSchedules(String repairType,
 boolean enabled)

Specified by:

setAllowParallelReplicaRepairAcrossSchedules in interface AutoRepairServiceMBean

setMVRepairEnabled

public void setMVRepairEnabled(String repairType,
 boolean enabled)

Specified by:

setMVRepairEnabled in interface AutoRepairServiceMBean

setRepairSessionTimeout

public void setRepairSessionTimeout(String repairType,
 String timeout)

Specified by:

setRepairSessionTimeout in interface AutoRepairServiceMBean

getOnGoingRepairHostIds

public Set<String> getOnGoingRepairHostIds(String repairType)

Specified by:

getOnGoingRepairHostIds in interface AutoRepairServiceMBean

setAutoRepairTokenRangeSplitterParameter

public void setAutoRepairTokenRangeSplitterParameter(String repairType,
 String key,
 String value)

Specified by:

setAutoRepairTokenRangeSplitterParameter in interface AutoRepairServiceMBean

setRepairByKeyspace

public void setRepairByKeyspace(String repairType,
 boolean repairByKeyspace)

Specified by:

setRepairByKeyspace in interface AutoRepairServiceMBean

setAutoRepairMaxRetriesCount

public void setAutoRepairMaxRetriesCount(String repairType,
 int retries)

Specified by:

setAutoRepairMaxRetriesCount in interface AutoRepairServiceMBean

setAutoRepairRetryBackoff

public void setAutoRepairRetryBackoff(String repairType,
 String interval)

Specified by:

setAutoRepairRetryBackoff in interface AutoRepairServiceMBean

setMixedMajorVersionRepairEnabled

public void setMixedMajorVersionRepairEnabled(boolean enabled)

Specified by:

setMixedMajorVersionRepairEnabled in interface AutoRepairServiceMBean