Package org.yamcs.timeline

Class ActivityScheduler

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.AbstractYamcsService

org.yamcs.timeline.ActivityScheduler

All Implemented Interfaces:

com.google.common.util.concurrent.Service, ActivityListener, ItemListener, YamcsService

public class ActivityScheduler
extends AbstractYamcsService
implements ItemListener, ActivityListener

Schedules activities in the timeline

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields inherited from class org.yamcs.AbstractYamcsService

config, serviceName

Constructor Summary

Constructors

Constructor	Description
ActivityScheduler()

Method Summary

Modifier and Type	Method	Description
protected void	doStart()
protected void	doStop()
Spec	getSpec()	Returns the valid configuration options for this service.
void	init(TimelineService timelineService, YConfiguration config)
void	onActivityUpdated(Activity activity)	An activity is created or updated
void	onItemCreated(TimelineItem item)	An item was created
void	onItemDeleted(TimelineItem item)	An item was deleted
void	onItemUpdated(TimelineItem item)	An item was updated
CompletableFuture<Activity>	startActivity(String id)

Methods inherited from class org.yamcs.AbstractYamcsService

findStream, getConfig, getYamcsInstance, init

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Constructor Details

ActivityScheduler

public ActivityScheduler()

Method Details

getSpec

public Spec getSpec()

Description copied from interface: YamcsService

Returns the valid configuration options for this service.

Specified by:

getSpec in interface YamcsService

Returns:

the argument specification, or null if the args should not be validated.

init

public void init(TimelineService timelineService,
 YConfiguration config)

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService

startActivity

public CompletableFuture<Activity> startActivity(String id)

onItemCreated

public void onItemCreated(TimelineItem item)

Description copied from interface: ItemListener

An item was created

Specified by:

onItemCreated in interface ItemListener

onItemUpdated

public void onItemUpdated(TimelineItem item)

Description copied from interface: ItemListener

An item was updated

Specified by:

onItemUpdated in interface ItemListener

onItemDeleted

public void onItemDeleted(TimelineItem item)

Description copied from interface: ItemListener

An item was deleted

Specified by:

onItemDeleted in interface ItemListener

onActivityUpdated

public void onActivityUpdated(Activity activity)

Description copied from interface: ActivityListener

An activity is created or updated

Specified by:

onActivityUpdated in interface ActivityListener