com.netflix.fenzo

Class TaskSchedulingService.Builder

java.lang.Object

com.netflix.fenzo.TaskSchedulingService.Builder

Enclosing class:

TaskSchedulingService

public static final class TaskSchedulingService.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
TaskSchedulingService	build() Creates a TaskSchedulingService based on the various builder methods you have chained.
TaskSchedulingService.Builder	withLoopIntervalMillis(long loopIntervalMillis) Use the given milli seconds as minimum delay between two consecutive scheduling iterations.
TaskSchedulingService.Builder	withMaxDelayMillis(long maxDelayMillis) Use the given milli seconds as the maximum delay between two consecutive scheduling iterations.
TaskSchedulingService.Builder	withPreSchedulingLoopHook(Action0 preHook) Use the given action to call before starting a new scheduling iteration.
TaskSchedulingService.Builder	withSchedulingResultCallback(Action1<SchedulingResult> callback) Use the given callback to give scheduling results to at the end of each scheduling iteration.
TaskSchedulingService.Builder	withTaskQuue(TaskQueue taskQ) Use the given instance of TaskQueue from which to get tasks to assign resource to.
TaskSchedulingService.Builder	withTaskScheduler(TaskScheduler taskScheduler) Use the given instance of TaskScheduler for scheduling resources.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

withTaskScheduler

public TaskSchedulingService.Builder withTaskScheduler(TaskScheduler taskScheduler)

Use the given instance of TaskScheduler for scheduling resources. A task scheduler must be provided before this builder can create the scheduling service.

Parameters:

taskScheduler - The task scheduler instance to use.

Returns:

this same Builder, suitable for further chaining or to build the TaskSchedulingService.

withSchedulingResultCallback

public TaskSchedulingService.Builder withSchedulingResultCallback(Action1<SchedulingResult> callback)

Use the given callback to give scheduling results to at the end of each scheduling iteration. A callback must be provided before this builder can create the scheduling service.

Parameters:

callback - The action to call with scheduling results.

Returns:

this same Builder, suitable for further chaining or to build the TaskSchedulingService.

withTaskQuue

public TaskSchedulingService.Builder withTaskQuue(TaskQueue taskQ)

Use the given instance of TaskQueue from which to get tasks to assign resource to. A task queue must be provided before this builder can create the scheduling service.

Parameters:

taskQ - The task queue from which to get tasks for assignment of resoruces.

Returns:

this same Builder, suitable for further chaining or to build the TaskSchedulingService.

withLoopIntervalMillis

public TaskSchedulingService.Builder withLoopIntervalMillis(long loopIntervalMillis)

Use the given milli seconds as minimum delay between two consecutive scheduling iterations. Default to 50.

Parameters:

loopIntervalMillis - The delay between consecutive scheduling iterations in milli seconds.

Returns:

this same Builder, suitable for further chaining or to build the TaskSchedulingService.

withMaxDelayMillis

public TaskSchedulingService.Builder withMaxDelayMillis(long maxDelayMillis)

Use the given milli seconds as the maximum delay between two consecutive scheduling iterations. Default to 5000. Delay between two iterations may be longer than the minimum delay specified using withLoopIntervalMillis(long) if the service notices no changes to the queue or there are no new VM leases input.

Parameters:

maxDelayMillis - The maximum delay between two consecutive scheduling iterations.

Returns:

this same Builder, suitable for further chaining or to build the TaskSchedulingService.

withPreSchedulingLoopHook

public TaskSchedulingService.Builder withPreSchedulingLoopHook(Action0 preHook)

Use the given action to call before starting a new scheduling iteration. This can be used, for example, to prepare for the next iteration by updating any state that user provided plugins may wish to use for constraints and fitness functions.

Parameters:

preHook - The callback to mark beginning of a new scheduling iteration.

Returns:

this same Builder, suitable for further chaining or to build the TaskSchedulingService.

build

public TaskSchedulingService build()

Creates a TaskSchedulingService based on the various builder methods you have chained.

Returns:

a TaskSchedulingService built according to the specifications you indicated