org.ow2.proactive_grid_cloud_portal.scheduler.client

Class SchedulerRestClient

java.lang.Object

org.ow2.proactive_grid_cloud_portal.scheduler.client.SchedulerRestClient

public class SchedulerRestClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SchedulerRestClient.JacksonContextResolver

Field Summary

Fields

Modifier and Type	Field and Description
static String	FILE_KEY
static String	VARIABLES_KEY

Constructor Summary

Constructors

Constructor and Description
SchedulerRestClient(String restEndpointURL)
SchedulerRestClient(String restEndpointURL, org.jboss.resteasy.client.jaxrs.ClientHttpEngine httpEngine)

Method Summary

Modifier and Type	Method and Description
boolean	delete(String sessionId, String dataspacePath, String path, List<String> includes, List<String> excludes)
boolean	download(String sessionId, String dataspacePath, String path, List<String> includes, List<String> excludes, File outputFile)
boolean	download(String sessionId, String dataspacePath, String path, List<String> includes, List<String> excludes, String outputPath)
String	getRestEndpointURL()
SchedulerRestInterface	getScheduler()
ListFile	list(String sessionId, String dataspacePath, String pathname)
Map<String,Object>	metadata(String sessionId, String dataspacePath, String pathname)
void	pullFile(String sessionId, String space, String path, String outputPath)
boolean	pushFile(String sessionId, String space, String path, String fileName, InputStream fileContent)
static void	registerGzipEncoding(org.jboss.resteasy.spi.ResteasyProviderFactory providerFactory)
JobIdData	reSubmit(String sessionId, String jobId, Map<String,String> variables, Map<String,String> genericInfos)
JobIdData	submitJobArchive(String sessionId, InputStream jobArchive)
JobIdData	submitJobArchive(String sessionId, InputStream jobArchive, Map<String,String> variables, Map<String,String> genericInfos)
List<JobIdDataAndError>	submitMultipleUrl(String sessionId, List<WorkflowUrlData> workflowUrlDataList)
JobIdData	submitUrl(String sessionId, String workflowUrl, Map<String,String> variables, Map<String,String> genericInfos)
JobIdData	submitXml(String sessionId, InputStream jobXml)
JobIdData	submitXml(String sessionId, InputStream jobXml, Map<String,String> variables)
JobIdData	submitXml(String sessionId, InputStream jobXml, Map<String,String> variables, Map<String,String> genericInfos)
JobIdData	submitXmlAs(String sessionId, InputStream jobXml, String user)
boolean	upload(String sessionId, File file, List<String> includes, List<String> excludes, String dataspacePath, String path)
boolean	upload(String sessionId, javax.ws.rs.core.StreamingOutput output, String encoding, String dataspace, String path)

Methods inherited from class java.lang.Object

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

Field Detail

VARIABLES_KEY

public static final String VARIABLES_KEY

See Also:

Constant Field Values

FILE_KEY

public static final String FILE_KEY

See Also:

Constant Field Values

Constructor Detail

SchedulerRestClient

public SchedulerRestClient(String restEndpointURL)

SchedulerRestClient

public SchedulerRestClient(String restEndpointURL,
                           org.jboss.resteasy.client.jaxrs.ClientHttpEngine httpEngine)

Method Detail

getRestEndpointURL

public String getRestEndpointURL()

registerGzipEncoding

public static void registerGzipEncoding(org.jboss.resteasy.spi.ResteasyProviderFactory providerFactory)

submitXmlAs

public JobIdData submitXmlAs(String sessionId,
                             InputStream jobXml,
                             String user)
                      throws Exception

Throws:

Exception

submitXml

public JobIdData submitXml(String sessionId,
                           InputStream jobXml)
                    throws Exception

Throws:

Exception

submitXml

public JobIdData submitXml(String sessionId,
                           InputStream jobXml,
                           Map<String,String> variables)
                    throws Exception

Throws:

Exception

submitXml

public JobIdData submitXml(String sessionId,
                           InputStream jobXml,
                           Map<String,String> variables,
                           Map<String,String> genericInfos)
                    throws Exception

Throws:

Exception

submitJobArchive

public JobIdData submitJobArchive(String sessionId,
                                  InputStream jobArchive)
                           throws Exception

Throws:

Exception

submitJobArchive

public JobIdData submitJobArchive(String sessionId,
                                  InputStream jobArchive,
                                  Map<String,String> variables,
                                  Map<String,String> genericInfos)
                           throws Exception

Throws:

Exception

pushFile

public boolean pushFile(String sessionId,
                        String space,
                        String path,
                        String fileName,
                        InputStream fileContent)
                 throws Exception

Throws:

Exception

pullFile

public void pullFile(String sessionId,
                     String space,
                     String path,
                     String outputPath)
              throws Exception

Throws:

Exception

upload

public boolean upload(String sessionId,
                      File file,
                      List<String> includes,
                      List<String> excludes,
                      String dataspacePath,
                      String path)
               throws Exception

Throws:

Exception

upload

public boolean upload(String sessionId,
                      javax.ws.rs.core.StreamingOutput output,
                      String encoding,
                      String dataspace,
                      String path)
               throws Exception

Throws:

Exception

download

public boolean download(String sessionId,
                        String dataspacePath,
                        String path,
                        List<String> includes,
                        List<String> excludes,
                        String outputPath)
                 throws Exception

Throws:

Exception

download

public boolean download(String sessionId,
                        String dataspacePath,
                        String path,
                        List<String> includes,
                        List<String> excludes,
                        File outputFile)
                 throws Exception

Throws:

Exception

delete

public boolean delete(String sessionId,
                      String dataspacePath,
                      String path,
                      List<String> includes,
                      List<String> excludes)
               throws Exception

Throws:

Exception

list

public ListFile list(String sessionId,
                     String dataspacePath,
                     String pathname)
              throws Exception

Throws:

Exception

metadata

public Map<String,Object> metadata(String sessionId,
                                   String dataspacePath,
                                   String pathname)
                            throws Exception

Throws:

Exception

submitUrl

public JobIdData submitUrl(String sessionId,
                           String workflowUrl,
                           Map<String,String> variables,
                           Map<String,String> genericInfos)
                    throws Exception

Throws:

Exception

submitMultipleUrl

public List<JobIdDataAndError> submitMultipleUrl(String sessionId,
                                                 List<WorkflowUrlData> workflowUrlDataList)
                                          throws Exception

Throws:

Exception

reSubmit

public JobIdData reSubmit(String sessionId,
                          String jobId,
                          Map<String,String> variables,
                          Map<String,String> genericInfos)
                   throws NotConnectedRestException

Throws:

NotConnectedRestException

getScheduler

public SchedulerRestInterface getScheduler()