org.hawkular.metrics.tasks.api

Interface TaskScheduler

All Known Implementing Classes:

TaskSchedulerImpl

public interface TaskScheduler

Author:

jsanda

Method Summary

Modifier and Type	Method and Description
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	shutdown()
rx.Observable<Lease>	start()
rx.Subscription	subscribe(rx.functions.Action1<Task2> onNext)
rx.Subscription	subscribe(rx.Subscriber<Task2> subscriber)

Method Detail

subscribe

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

subscribe

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

getTasks

rx.Observable<Task2> getTasks()

start

rx.Observable<Lease> start()

scheduleTask

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

shutdown

void shutdown()

getFinishedTimeSlices

rx.Observable<Long> getFinishedTimeSlices()

isRunning

boolean isRunning()