Package gov.nasa.jpl.aerie.merlin.driver.engine

Class TaskFrame<Job>

java.lang.Object

gov.nasa.jpl.aerie.merlin.driver.engine.TaskFrame<Job>

public final class TaskFrame<Job>
extends Object

A TaskFrame describes a task-in-progress, including its current series of events and any jobs that have branched off.

   branches[0].base |-> branches[1].base  ... |-> branches[n].base   |-> tip
                    +-> branches[0].job       +-> branches[n-1].job  +-> branches[n].job
 

Method Summary

Modifier and Type	Method	Description
void	emit(Event event)
Optional<gov.nasa.jpl.aerie.merlin.protocol.types.Duration>	getExpiry(Query<?> query)
<State> Optional<State>	getState(Query<State> query)
static <Job> EventGraph<Event>	run(Job job, LiveCells context, BiConsumer<Job,TaskFrame<Job>> executor)
void	signal(Job target)

Methods inherited from class java.lang.Object

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

Method Details

run

public static <Job> EventGraph<Event> run(Job job,
 LiveCells context,
 BiConsumer<Job,TaskFrame<Job>> executor)

getState

public <State> Optional<State> getState(Query<State> query)

getExpiry

public Optional<gov.nasa.jpl.aerie.merlin.protocol.types.Duration> getExpiry(Query<?> query)

emit

public void emit(Event event)

signal

public void signal(Job target)