X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;ds=sidebyside;f=cms%2Forg.argeo.slc.api%2Fsrc%2Forg%2Fargeo%2Fslc%2Fexecution%2FSlcAgent.java;fp=cms%2Forg.argeo.slc.api%2Fsrc%2Forg%2Fargeo%2Fslc%2Fexecution%2FSlcAgent.java;h=039724f509274d1a60c006ced371ce6b825ff84f;hb=ecc22e604e47533c79de9cecdcdeacbc752cbff1;hp=0000000000000000000000000000000000000000;hpb=e07ded4632e53f8b8869763bc1f1f4091361e76e;p=gpl%2Fargeo-slc.git

diff --git a/cms/org.argeo.slc.api/src/org/argeo/slc/execution/SlcAgent.java b/cms/org.argeo.slc.api/src/org/argeo/slc/execution/SlcAgent.java
new file mode 100644
index 000000000..039724f50
--- /dev/null
+++ b/cms/org.argeo.slc.api/src/org/argeo/slc/execution/SlcAgent.java
@@ -0,0 +1,51 @@
+package org.argeo.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<URI> 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<ExecutionModuleDescriptor> listExecutionModuleDescriptors();
+
+	/** @return true if still alive. */
+	public boolean ping();
+}