Package com.linkedin.venice.utils

Class MockTestStateModelFactory

java.lang.Object

org.apache.helix.participant.statemachine.StateModelFactory<org.apache.helix.participant.statemachine.StateModel>

com.linkedin.venice.utils.MockTestStateModelFactory

public class MockTestStateModelFactory
extends org.apache.helix.participant.statemachine.StateModelFactory<org.apache.helix.participant.statemachine.StateModel>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MockTestStateModelFactory.OnlineOfflineStateModel

Constructor Summary

Constructors

Constructor	Description
MockTestStateModelFactory(VeniceOfflinePushMonitorAccessor offlinePushStatusAccessor)

Method Summary

Modifier and Type	Method	Description
org.apache.helix.participant.statemachine.StateModel	createNewStateModel(java.lang.String resourceName, java.lang.String partitionName)
java.util.List<MockTestStateModelFactory.OnlineOfflineStateModel>	getModelList(java.lang.String resourceName, int partitionId)
void	makeTransitionCompleted(java.lang.String resourceName, int partitionId)
void	makeTransitionError(java.lang.String resourceName, int partitionId)
void	setBlockTransition(boolean isDelay)
void	stopAllStateModelThreads()

Methods inherited from class org.apache.helix.participant.statemachine.StateModelFactory

createAndAddBatchMessageWrapper, createAndAddStateModel, createAndAddStateModel, createBatchMessageWrapper, createNewStateModel, getBatchMessageWrapper, getExecutorService, getExecutorService, getPartitionSet, getPartitionSet, getResourceSet, getStateModel, getStateModel, removeStateModel, removeStateModel

Methods inherited from class java.lang.Object

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

Constructor Detail

MockTestStateModelFactory

public MockTestStateModelFactory(VeniceOfflinePushMonitorAccessor offlinePushStatusAccessor)

Method Detail

stopAllStateModelThreads

public void stopAllStateModelThreads()

createNewStateModel

public org.apache.helix.participant.statemachine.StateModel createNewStateModel(java.lang.String resourceName,
                                                                                java.lang.String partitionName)

Overrides:

createNewStateModel in class org.apache.helix.participant.statemachine.StateModelFactory<org.apache.helix.participant.statemachine.StateModel>

setBlockTransition

public void setBlockTransition(boolean isDelay)

makeTransitionCompleted

public void makeTransitionCompleted(java.lang.String resourceName,
                                    int partitionId)

getModelList

public java.util.List<MockTestStateModelFactory.OnlineOfflineStateModel> getModelList(java.lang.String resourceName,
                                                                                      int partitionId)

makeTransitionError

public void makeTransitionError(java.lang.String resourceName,
                                int partitionId)