at.ac.tuwien.dsg.cloud.elise.master.RESTService

Class EliseCommunicationService

java.lang.Object

at.ac.tuwien.dsg.cloud.elise.master.RESTService.EliseCommunicationService

All Implemented Interfaces:

at.ac.tuwien.dsg.cloud.elise.master.RESTImp.EliseCommunicationInterface

@Path(value="/communication")
public class EliseCommunicationService
extends Object
implements at.ac.tuwien.dsg.cloud.elise.master.RESTImp.EliseCommunicationInterface

This service contains APIs to communicate with distributed collectors to gather information

Author:

Duc-Hung Le

Constructor Summary

Constructors

Constructor and Description
EliseCommunicationService()

Method Summary

Modifier and Type	Method and Description
String	count() Get the information of available conductors and collectors which are running and registered.
String	getQueryProcessStatus(String queryUUID) Query the status of a query.
String	health()
static String	padLeft(String s, int n)
String	querySetOfInstance(at.ac.tuwien.dsg.cloud.salsa.messaging.model.Elise.EliseQuery query, boolean isUpdated, boolean isNotified) Send a query to all the conductors, which then will trigger collector module, collect the information, and update to the central service.
String	querySetOfInstances(at.ac.tuwien.dsg.cloud.salsa.messaging.model.Elise.EliseQuery query)

Methods inherited from class java.lang.Object

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

Constructor Detail

EliseCommunicationService

public EliseCommunicationService()

Method Detail

count

public String count()

Get the information of available conductors and collectors which are running and registered.

Specified by:

count in interface at.ac.tuwien.dsg.cloud.elise.master.RESTImp.EliseCommunicationInterface

Returns:

The description of all conductors.

querySetOfInstance

public String querySetOfInstance(at.ac.tuwien.dsg.cloud.salsa.messaging.model.Elise.EliseQuery query,
                                 @DefaultValue(value="false") @QueryParam(value="isUpdated")
                                 boolean isUpdated,
                                 @DefaultValue(value="false") @QueryParam(value="notify")
                                 boolean isNotified)

Send a query to all the conductors, which then will trigger collector module, collect the information, and update to the central service.

Specified by:

querySetOfInstance in interface at.ac.tuwien.dsg.cloud.elise.master.RESTImp.EliseCommunicationInterface

Parameters:

query - A query to specify which information to be collected

isUpdated - The information will be update continously or this is an one-time query

isNotified - The change will be notify to the topic

Returns:

An UUID of the query, which can be used to trace the status of this query.

querySetOfInstances

public String querySetOfInstances(at.ac.tuwien.dsg.cloud.salsa.messaging.model.Elise.EliseQuery query)

Specified by:

querySetOfInstances in interface at.ac.tuwien.dsg.cloud.elise.master.RESTImp.EliseCommunicationInterface

health

public String health()

padLeft

public static String padLeft(String s,
                             int n)

getQueryProcessStatus

public String getQueryProcessStatus(String queryUUID)

Query the status of a query.

Specified by:

getQueryProcessStatus in interface at.ac.tuwien.dsg.cloud.elise.master.RESTImp.EliseCommunicationInterface

Parameters:

queryUUID - The UUID of the query

Returns:

A list of conductors that are working for this query and the status of each