String |
JavaScriptWorkerSelectStrategy.SelectorFunction.apply(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task) |
ImmutableWorkerInfo |
WorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task)
Customizable logic for selecting a worker to run a task.
|
ImmutableWorkerInfo |
JavaScriptWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task) |
ImmutableWorkerInfo |
FillCapacityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task) |
ImmutableWorkerInfo |
EqualDistributionWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task) |
static ImmutableWorkerInfo |
WorkerSelectUtils.selectWorker(Task task,
Map<String,ImmutableWorkerInfo> allWorkers,
WorkerTaskRunnerConfig workerTaskRunnerConfig,
AffinityConfig affinityConfig,
Function<com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo>,ImmutableWorkerInfo> workerSelector)
|