public class SimpleResourceManagementStrategy extends Object implements ResourceManagementStrategy
| Constructor and Description |
|---|
SimpleResourceManagementStrategy(AutoScalingStrategy autoScalingStrategy,
SimpleResourceManagementConfig config,
com.google.common.base.Supplier<WorkerSetupData> workerSetupDataRef) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
doProvision(Collection<RemoteTaskRunnerWorkItem> pendingTasks,
Collection<ZkWorker> zkWorkers) |
boolean |
doTerminate(Collection<RemoteTaskRunnerWorkItem> pendingTasks,
Collection<ZkWorker> zkWorkers) |
ScalingStats |
getStats() |
@Inject public SimpleResourceManagementStrategy(AutoScalingStrategy autoScalingStrategy, SimpleResourceManagementConfig config, com.google.common.base.Supplier<WorkerSetupData> workerSetupDataRef)
public boolean doProvision(Collection<RemoteTaskRunnerWorkItem> pendingTasks, Collection<ZkWorker> zkWorkers)
doProvision in interface ResourceManagementStrategypublic boolean doTerminate(Collection<RemoteTaskRunnerWorkItem> pendingTasks, Collection<ZkWorker> zkWorkers)
doTerminate in interface ResourceManagementStrategypublic ScalingStats getStats()
getStats in interface ResourceManagementStrategyCopyright © 2014. All rights reserved.