public class ActionManager extends Object
Constructor and Description |
---|
ActionManager(long schedulerSleepTime,
long actionTimeout,
ActionQueue aq,
Clusters fsm,
ActionDBAccessor db,
HostsMap hostsMap,
ServerActionManager serverActionManager,
com.google.inject.persist.UnitOfWork unitOfWork,
RequestFactory requestFactory,
Configuration configuration) |
@Inject public ActionManager(long schedulerSleepTime, long actionTimeout, ActionQueue aq, Clusters fsm, ActionDBAccessor db, HostsMap hostsMap, ServerActionManager serverActionManager, com.google.inject.persist.UnitOfWork unitOfWork, RequestFactory requestFactory, Configuration configuration)
public void start()
public void shutdown()
public void sendActions(List<Stage> stages, ExecuteActionRequest actionRequest) throws AmbariException
AmbariException
public void sendActions(Request request, ExecuteActionRequest executeActionRequest)
public List<Request> getRequests(Collection<Long> requestIds)
public Stage getAction(long requestId, long stageId)
public List<Stage> getActions(long requestId)
requestId
- the request idpublic void processTaskResponse(String hostname, List<CommandReport> reports)
public boolean isInProgressCommand(CommandReport report)
report
- public void handleLostHost(String host)
public long getNextRequestId()
public List<HostRoleCommand> getRequestTasks(long requestId)
public List<HostRoleCommand> getAllTasksByRequestIds(Collection<Long> requestIds)
public List<HostRoleCommand> getTasksByRequestAndTaskIds(Collection<Long> requestIds, Collection<Long> taskIds)
public Collection<HostRoleCommand> getTasks(Collection<Long> taskIds)
public List<Stage> getRequestsByHostRoleStatus(Set<HostRoleStatus> statuses)
public List<Long> getRequestsByStatus(RequestStatus status)
public String getRequestContext(long requestId)
Copyright © 2017. All rights reserved.