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 TrianaClient
ClientException
public void run(HistoryClipIn history) throws ClientException
run
in interface TrianaClient
ClientException
public void run(IoConfiguration ioConfiguration) throws ClientException
TrianaClient
run
in interface TrianaClient
ClientException
public SchedulerInterface getSchedulerInterface()
getSchedulerInterface
in interface TrianaServer
public void runTask(Task task) throws SchedulerException
runTask
in interface TrianaServer
SchedulerException
public void pause() throws ClientException
pause
in interface TrianaClient
ClientException
public void reset() throws ClientException
reset
in interface TrianaClient
ClientException
public void flush() throws ClientException
flush
in interface TrianaClient
ClientException
public void dispose() throws ClientException
dispose
in interface TrianaClient
ClientException
public void notifyError(RunnableInstance runnable, java.lang.String message)
notifyError
in interface TrianaServer