Interface AbstractCoordinatorTestCase.CoordinatorStrategy
- All Superinterfaces:
AutoCloseable,Closeable
- All Known Implementing Classes:
AbstractCoordinatorTestCase.DefaultCoordinatorStrategy
- Enclosing class:
AbstractCoordinatorTestCase
-
Method Summary
Modifier and TypeMethodDescriptiondefault voidclose()createFreshPersistedState(DiscoveryNode localNode, BooleanSupplier disruptStorage, ThreadPool threadPool) createPersistedStateFromExistingState(DiscoveryNode newLocalNode, CoordinationState.PersistedState oldState, Function<Metadata, Metadata> adaptGlobalMetadata, Function<Long, Long> adaptCurrentTerm, LongSupplier currentTimeInMillisSupplier, NamedWriteableRegistry namedWriteableRegistry, BooleanSupplier disruptStorage, ThreadPool threadPool) getCoordinationServices(ThreadPool threadPool, Settings settings, ClusterSettings clusterSettings, CoordinationState.PersistedState persistedState, AbstractCoordinatorTestCase.DisruptibleRegisterConnection disruptibleRegisterConnection) default boolean
-
Method Details
-
getCoordinationServices
AbstractCoordinatorTestCase.CoordinationServices getCoordinationServices(ThreadPool threadPool, Settings settings, ClusterSettings clusterSettings, CoordinationState.PersistedState persistedState, AbstractCoordinatorTestCase.DisruptibleRegisterConnection disruptibleRegisterConnection) -
createFreshPersistedState
CoordinationState.PersistedState createFreshPersistedState(DiscoveryNode localNode, BooleanSupplier disruptStorage, ThreadPool threadPool) -
createPersistedStateFromExistingState
CoordinationState.PersistedState createPersistedStateFromExistingState(DiscoveryNode newLocalNode, CoordinationState.PersistedState oldState, Function<Metadata, Metadata> adaptGlobalMetadata, Function<Long, Long> adaptCurrentTerm, LongSupplier currentTimeInMillisSupplier, NamedWriteableRegistry namedWriteableRegistry, BooleanSupplier disruptStorage, ThreadPool threadPool) -
close
default void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
verifyElectionSchedulerState
default boolean verifyElectionSchedulerState(AbstractCoordinatorTestCase.Cluster.ClusterNode clusterNode)
-