org.hawkular.metrics.tasks.impl

Class TaskSchedulerImpl

java.lang.Object

org.hawkular.metrics.tasks.impl.TaskSchedulerImpl

All Implemented Interfaces:

TaskScheduler

public class TaskSchedulerImpl
extends Object
implements TaskScheduler

Author:

jsanda

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_LEASE_TTL

Constructor Summary

Constructors

Constructor and Description
TaskSchedulerImpl(RxSession session, Queries queries)

Method Summary

Modifier and Type	Method and Description
rx.Observable<Task2>	findTask(UUID id)
rx.Observable<Long>	getFinishedTimeSlices()
rx.Observable<Task2>	getTasks()
boolean	isRunning()
rx.Observable<Task2>	scheduleTask(String name, String groupKey, int executionOrder, Map<String,String> parameters, Trigger trigger)
void	setTickScheduler(rx.Scheduler scheduler)
void	shutdown()
rx.Observable<Lease>	start() Starts the scheduler so that it starts emitting tasks for execution.
rx.Subscription	subscribe(rx.functions.Action1<Task2> onNext) Subscribe a callback that will be responsible for executing tasks.
rx.Subscription	subscribe(rx.Subscriber<Task2> subscriber) Subscribe a callback that will be responsible for executing tasks.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_LEASE_TTL

public static final int DEFAULT_LEASE_TTL

See Also:

Constant Field Values

Constructor Detail

TaskSchedulerImpl

public TaskSchedulerImpl(RxSession session,
                         Queries queries)

Method Detail

setTickScheduler

public void setTickScheduler(rx.Scheduler scheduler)

subscribe

public rx.Subscription subscribe(rx.functions.Action1<Task2> onNext)

Subscribe a callback that will be responsible for executing tasks.

Specified by:

subscribe in interface TaskScheduler

Parameters:

onNext - The task execution callback

Returns:

A subscription which can be used to stop receiving task notifications.

subscribe

public rx.Subscription subscribe(rx.Subscriber<Task2> subscriber)

Subscribe a callback that will be responsible for executing tasks.

Specified by:

subscribe in interface TaskScheduler

Parameters:

subscriber - The callback

Returns:

A subscription which can be used to stop receiving task notifications.

getFinishedTimeSlices

public rx.Observable<Long> getFinishedTimeSlices()

Specified by:

getFinishedTimeSlices in interface TaskScheduler

isRunning

public boolean isRunning()

Specified by:

isRunning in interface TaskScheduler

getTasks

public rx.Observable<Task2> getTasks()

Specified by:

getTasks in interface TaskScheduler

start

public rx.Observable<Lease> start()

Starts the scheduler so that it starts emitting tasks for execution.

Specified by:

start in interface TaskScheduler

Returns:

An observable that emits leases that are processed by this TaskScheduler object. The observable emits a lease only after it has been fully processed. This means all tasks belonging to the task have been executed, and the lease has been marked finished. Note that the observable is hot; in other words, it emits leases regardless of wehther or not there are any subscriptions.

shutdown

public void shutdown()

Specified by:

shutdown in interface TaskScheduler

findTask

public rx.Observable<Task2> findTask(UUID id)

scheduleTask

public rx.Observable<Task2> scheduleTask(String name,
                                         String groupKey,
                                         int executionOrder,
                                         Map<String,String> parameters,
                                         Trigger trigger)

Specified by:

scheduleTask in interface TaskScheduler