public class TaskMaster extends Object
Constructor and Description |
---|
TaskMaster(TaskQueueConfig taskQueueConfig,
TaskLockbox taskLockbox,
TaskStorage taskStorage,
TaskActionClientFactory taskActionClientFactory,
DruidNode selfNode,
TaskRunnerFactory runnerFactory,
ServiceAnnouncer serviceAnnouncer,
CoordinatorOverlordServiceConfig coordinatorOverlordServiceConfig,
ServiceEmitter emitter,
SupervisorManager supervisorManager,
OverlordHelperManager overlordHelperManager,
DruidLeaderSelector overlordLeaderSelector) |
Modifier and Type | Method and Description |
---|---|
String |
getCurrentLeader() |
com.google.common.base.Optional<ScalingStats> |
getScalingStats() |
com.google.common.base.Optional<SupervisorManager> |
getSupervisorManager() |
com.google.common.base.Optional<TaskActionClient> |
getTaskActionClient(Task task) |
com.google.common.base.Optional<TaskQueue> |
getTaskQueue() |
com.google.common.base.Optional<TaskRunner> |
getTaskRunner() |
boolean |
isLeader() |
void |
start()
Starts waiting for leadership.
|
void |
stop()
Stops forever (not just this particular leadership session).
|
@Inject public TaskMaster(TaskQueueConfig taskQueueConfig, TaskLockbox taskLockbox, TaskStorage taskStorage, TaskActionClientFactory taskActionClientFactory, DruidNode selfNode, TaskRunnerFactory runnerFactory, ServiceAnnouncer serviceAnnouncer, CoordinatorOverlordServiceConfig coordinatorOverlordServiceConfig, ServiceEmitter emitter, SupervisorManager supervisorManager, OverlordHelperManager overlordHelperManager, DruidLeaderSelector overlordLeaderSelector)
public void start()
public void stop()
public boolean isLeader()
public String getCurrentLeader()
public com.google.common.base.Optional<TaskRunner> getTaskRunner()
public com.google.common.base.Optional<TaskQueue> getTaskQueue()
public com.google.common.base.Optional<TaskActionClient> getTaskActionClient(Task task)
public com.google.common.base.Optional<ScalingStats> getScalingStats()
public com.google.common.base.Optional<SupervisorManager> getSupervisorManager()
Copyright © 2011–2018. All rights reserved.