public class LocalServer extends java.lang.Object implements TrianaClient, TrianaServer
| Constructor and Description |
|---|
LocalServer(TaskGraph taskgraph)
Constructs a local server.
|
LocalServer(TaskGraph taskgraph,
SchedulerInterface scheduler) |
| Modifier and Type | Method and Description |
|---|---|
void |
dispose()
Disposes of the server
|
void |
flush()
Sends a message to the server to flush the taskgraph
|
SchedulerInterface |
getSchedulerInterface() |
TaskGraph |
getTaskGraph() |
void |
notifyError(RunnableInstance runnable,
java.lang.String message)
Called be a runnable instance to notify that an error has occured
|
void |
pause()
Sends a message to the server to stop running the taskgraph.
|
void |
reset()
Sends a message to the server to reset the taskgraph.
|
void |
run()
Sends a message to the sever to run the taskgraph.
|
void |
run(HistoryClipIn history)
Sends a message to the sever to run the taskgraph.
|
void |
run(IoConfiguration ioConfiguration)
Sends a message to the server to run the taskgraph, with a configuration of inputs.
|
void |
runTask(Task task)
Sends a message to the sever to run the specified task within a running taskgraph
|
public LocalServer(TaskGraph taskgraph)
public LocalServer(TaskGraph taskgraph, SchedulerInterface scheduler)
public TaskGraph getTaskGraph()
public void run()
throws ClientException
run in interface TrianaClientClientExceptionpublic void run(HistoryClipIn history) throws ClientException
run in interface TrianaClientClientExceptionpublic void run(IoConfiguration ioConfiguration) throws ClientException
TrianaClientrun in interface TrianaClientClientExceptionpublic SchedulerInterface getSchedulerInterface()
getSchedulerInterface in interface TrianaServerpublic void runTask(Task task) throws SchedulerException
runTask in interface TrianaServerSchedulerExceptionpublic void pause()
throws ClientException
pause in interface TrianaClientClientExceptionpublic void reset()
throws ClientException
reset in interface TrianaClientClientExceptionpublic void flush()
throws ClientException
flush in interface TrianaClientClientExceptionpublic void dispose()
throws ClientException
dispose in interface TrianaClientClientExceptionpublic void notifyError(RunnableInstance runnable, java.lang.String message)
notifyError in interface TrianaServer