X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.api.slc%2Fsrc%2Forg%2Fargeo%2Fapi%2Fslc%2Fexecution%2FSlcAgent.java;fp=org.argeo.api.slc%2Fsrc%2Forg%2Fargeo%2Fapi%2Fslc%2Fexecution%2FSlcAgent.java;h=ff7161b380e01a09c76729a2ae8224d2b263494a;hb=d07cf3c7dfdeafa2b1efafe547b54d56a8b52ced;hp=0000000000000000000000000000000000000000;hpb=8596685647867307b862b8a89742b6a62ba75fcd;p=gpl%2Fargeo-slc.git diff --git a/org.argeo.api.slc/src/org/argeo/api/slc/execution/SlcAgent.java b/org.argeo.api.slc/src/org/argeo/api/slc/execution/SlcAgent.java new file mode 100644 index 000000000..ff7161b38 --- /dev/null +++ b/org.argeo.api.slc/src/org/argeo/api/slc/execution/SlcAgent.java @@ -0,0 +1,51 @@ +package org.argeo.api.slc.execution; + +import java.net.URI; +import java.util.List; + +/** + * A local agent can run SLC processes. It is responsible for creating their + * threads and integrating them with various UIs. It typically wraps + * {@link ExecutionModulesManager} which is used to run flows synchronously at a + * lower level. + */ +public interface SlcAgent { + /** Agent unique identifier */ + public String getAgentUuid(); + + /** Execute / take part to this process */ + public void process(ExecutionProcess process); + + /** + * Asynchronously processes the flows defined as URIs, or interpret a single + * UUID URN as a scheduled or template process. + * + * @return the UUID of the process launched. + */ + public String process(List uris); + + /** Kills this process */ + public void kill(String processUuid); + + /** + * Wait for this process to finish. returns immediately if it does not + * exist. + * + * @param millis + * can be null + */ + public void waitFor(String processUuid, Long millis); + + /** + * Describe all the flows provided by this execution module. Typically + * called in order to build a realized flow. + */ + public ExecutionModuleDescriptor getExecutionModuleDescriptor( + String moduleName, String version); + + /** List all execution modules which can be processed by this agent. */ + public List listExecutionModuleDescriptors(); + + /** @return true if still alive. */ + public boolean ping(); +}