com.netflix.fenzo.samples

Class SampleFramework

java.lang.Object

com.netflix.fenzo.samples.SampleFramework

public class SampleFramework
extends java.lang.Object

A sample Mesos framework that shows a sample usage of Fenzo TaskScheduler.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SampleFramework.MesosScheduler A sample mesos scheduler that shows how mesos callbacks can be setup for use with Fenzo TaskScheduler.

Constructor Summary

Constructors

Constructor and Description
SampleFramework(java.util.concurrent.BlockingQueue<TaskRequest> taskQueue, java.lang.String mesosMaster, Action1<java.lang.String> onTaskComplete, Func1<java.lang.String,java.lang.String> taskCmdGetter) Create a sample mesos framework with the given task queue and mesos master connection string.

Method Summary

Modifier and Type	Method and Description
void	shutdown() Shuts down the Mesos driver.
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

SampleFramework

public SampleFramework(java.util.concurrent.BlockingQueue<TaskRequest> taskQueue,
                       java.lang.String mesosMaster,
                       Action1<java.lang.String> onTaskComplete,
                       Func1<java.lang.String,java.lang.String> taskCmdGetter)

Create a sample mesos framework with the given task queue and mesos master connection string. As would be typical for frameworks that wish to use Fenzo task scheduler, a lease queue is created for mesos scheduler callback to insert offers received from mesos. This sample implementation obtains the tasks to run via a task queue. The runAll() method implements the scheduling loop that continuously takes pending tasks from the queue and uses Fenzo's task scheduler to assign resources to them. The task scheduler created in this sample is a rather simple one, with no advanced features.

Parameters:

taskQueue - The task queue.

mesosMaster - Connection string for mesos master.

onTaskComplete - A single argument action trigger to invoke upon task completion, with task ID is the argument.

taskCmdGetter - A single argument function to invoke to get the command line to execute for a given task ID, passed as the only argument.

Method Detail

shutdown

public void shutdown()

Shuts down the Mesos driver.

start

public void start()