public class StateMachineController extends Object
Constructor and Description |
---|
StateMachineController(Job restoreJob,
MessageEmitter messageEmitter,
RestoreMetricsManager restoreMetricsManager) |
StateMachineController(Job restoreJob,
MessageEmitter messageEmitter,
RestoreMetricsManager restoreMetricsManager,
Map<TopicIdPartition,FtpsStateForRestore> ftpsMap) |
Modifier and Type | Method and Description |
---|---|
static MessageRequest |
buildPreConditionCheckRequest(FiniteStateMachine finiteStateMachine) |
void |
buildStateMachinesFromDB()
Building the FSM maps when starting up.
|
int |
completedCount() |
int |
failedCount() |
FiniteStateMachine |
getFiniteStateMachineByTopicPartition(org.apache.kafka.common.TopicPartition tp) |
int |
inProgressCount() |
boolean |
isAllTasksDone() |
void |
maybeMarkJobCompleted() |
void |
moveToCompleteSet(org.apache.kafka.common.TopicPartition tp) |
void |
moveToFailMap(org.apache.kafka.common.TopicPartition tp) |
void |
moveToInprogressMap(org.apache.kafka.common.TopicPartition tp) |
FiniteStateMachine |
pickOneNewPartitionToStartRestore() |
String |
status() |
int |
waitingCount() |
public StateMachineController(Job restoreJob, MessageEmitter messageEmitter, RestoreMetricsManager restoreMetricsManager)
public StateMachineController(Job restoreJob, MessageEmitter messageEmitter, RestoreMetricsManager restoreMetricsManager, Map<TopicIdPartition,FtpsStateForRestore> ftpsMap)
public void buildStateMachinesFromDB()
public int waitingCount()
public int inProgressCount()
public int failedCount()
public int completedCount()
public void moveToFailMap(org.apache.kafka.common.TopicPartition tp)
public void moveToCompleteSet(org.apache.kafka.common.TopicPartition tp)
public void moveToInprogressMap(org.apache.kafka.common.TopicPartition tp)
public FiniteStateMachine pickOneNewPartitionToStartRestore()
public FiniteStateMachine getFiniteStateMachineByTopicPartition(org.apache.kafka.common.TopicPartition tp)
public static MessageRequest buildPreConditionCheckRequest(FiniteStateMachine finiteStateMachine)
public boolean isAllTasksDone()
public String status()
public void maybeMarkJobCompleted()