Package org.apache.cassandra.repair

Interface SharedContext

All Known Implementing Classes:

SharedContext.ForwardingSharedContext, SharedContext.Global

public interface SharedContext

Access methods to shared resources and services.

In many parts of the code base we reach into the global space to pull out singletons, but this makes testing much harder; the main goals for this type is to make users easier to test. See SharedContext.Global.instance for the main production path

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	SharedContext.ForwardingSharedContext
static class	SharedContext.Global

Method Summary

Modifier and Type	Method	Description
InetAddressAndPort	broadcastAddressAndPort()
Clock	clock()
ICompactionManager	compactionManager()
ExecutorFactory	executorFactory()
IFailureDetector	failureDetector()
IGossiper	gossiper()
MBeanWrapper	mbean()
MessageDelivery	messaging()
ScheduledExecutorPlus	nonPeriodicTasks()
ScheduledExecutorPlus	optionalTasks()
PaxosRepairState	paxosRepairState()
PendingRangeCalculatorService	pendingRangeCalculator()
Supplier<Random>	random()
ActiveRepairService	repair()
TableRepairManager	repairManager(ColumnFamilyStore store)
ScheduledExecutorPlus	scheduledTasks()
IEndpointSnitch	snitch()
StreamExecutor	streamExecutor()
IValidationManager	validationManager()
default SharedContext	withMessaging(MessageDelivery messaging)

Method Details

broadcastAddressAndPort

InetAddressAndPort broadcastAddressAndPort()

random

Supplier<Random> random()

clock

Clock clock()

executorFactory

ExecutorFactory executorFactory()

mbean

MBeanWrapper mbean()

optionalTasks

ScheduledExecutorPlus optionalTasks()

nonPeriodicTasks

ScheduledExecutorPlus nonPeriodicTasks()

scheduledTasks

ScheduledExecutorPlus scheduledTasks()

messaging

MessageDelivery messaging()

withMessaging

default SharedContext withMessaging(MessageDelivery messaging)

failureDetector

IFailureDetector failureDetector()

snitch

IEndpointSnitch snitch()

gossiper

IGossiper gossiper()

compactionManager

ICompactionManager compactionManager()

repair

ActiveRepairService repair()

validationManager

IValidationManager validationManager()

repairManager

TableRepairManager repairManager(ColumnFamilyStore store)

streamExecutor

StreamExecutor streamExecutor()

pendingRangeCalculator

PendingRangeCalculatorService pendingRangeCalculator()

paxosRepairState

PaxosRepairState paxosRepairState()