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

Interface EliseManager

@Path(value="/manager")
public interface EliseManager

For managing distributed components of ELISE

Author:

Duc-Hung Le

Method Summary

Modifier and Type	Method and Description
String	cleanDB()
void	deleteGlobalIdentification(String globalID)
javax.ws.rs.core.Response	getCollectorArtifact(String collectorName)
String	getCollectorNameList()
at.ac.tuwien.dsg.cloud.elise.collectorinterfaces.models.ConductorDescription	getConductor(String paramString)
List<at.ac.tuwien.dsg.cloud.elise.collectorinterfaces.models.ConductorDescription>	getConductorList()
String	health()
void	pushCollectorToConductor(String configuration, String conductorID, String collectorName) Send a message to inject a collector with name and configure into the conductor with ID This function publish message to all the conductor, which the conductor will filter later.
String	registerConductor(at.ac.tuwien.dsg.cloud.elise.collectorinterfaces.models.ConductorDescription paramCollectorDescription)
String	removeConductor(String paramString)
void	ResynConductors()
void	runConductorViaSalsa(String pioneerID) To request the pioneer to run a conductor.
List<GlobalIdentification>	updateComposedIdentification(LocalIdentification si, String possibleGlobalID) Update a identification to the identification database As the global ID is assign by SALSA, the possibleGlobalID is for the creation of new GlobalID
String	updateConductor(at.ac.tuwien.dsg.cloud.elise.collectorinterfaces.models.ConductorDescription paramCollectorDescription)

Method Detail

registerConductor

@POST
 @Path(value="/conductor")
 @Consumes(value="application/json")
 @Produces(value="text/plain")
String registerConductor(at.ac.tuwien.dsg.cloud.elise.collectorinterfaces.models.ConductorDescription paramCollectorDescription)

updateConductor

@PUT
 @Path(value="/conductor")
 @Consumes(value="application/json")
String updateConductor(at.ac.tuwien.dsg.cloud.elise.collectorinterfaces.models.ConductorDescription paramCollectorDescription)

getConductor

@GET
 @Path(value="/conductor/{conductorID}")
 @Produces(value="application/json")
at.ac.tuwien.dsg.cloud.elise.collectorinterfaces.models.ConductorDescription getConductor(@PathParam(value="conductorID")
                                                                                                                                                                             String paramString)

removeConductor

@DELETE
 @Path(value="/conductor/{conductorID}")
 @Produces(value="text/plain")
String removeConductor(@PathParam(value="conductorID")
                                                                                                       String paramString)

getConductorList

@GET
 @Path(value="/conductor")
 @Produces(value="application/json")
List<at.ac.tuwien.dsg.cloud.elise.collectorinterfaces.models.ConductorDescription> getConductorList()

runConductorViaSalsa

@POST
 @Path(value="/conductor/salsa/{pioneerID}")
void runConductorViaSalsa(@PathParam(value="conductorID")
                                                                             String pioneerID)

To request the pioneer to run a conductor. If the pioneerID=salsa, this will run conductor directly by ELISE here

Parameters:

pioneerID -

pushCollectorToConductor

@POST
 @Path(value="/conductor/{conductorID}/collector/{collectorName}")
 @Consumes(value="text/plain")
void pushCollectorToConductor(String configuration,
                                                                                                                                      @PathParam(value="conductorID")
                                                                                                                                      String conductorID,
                                                                                                                                      @PathParam(value="collectorName")
                                                                                                                                      String collectorName)

Send a message to inject a collector with name and configure into the conductor with ID This function publish message to all the conductor, which the conductor will filter later.

getCollectorArtifact

@GET
 @Path(value="/collector/{collectorName}")
 @Produces(value="application/octet-stream")
javax.ws.rs.core.Response getCollectorArtifact(@PathParam(value="collectorName")
                                                                                                                                            String collectorName)

getCollectorNameList

@GET
 @Path(value="/collector")
String getCollectorNameList()

ResynConductors

@POST
 @Path(value="/conductor/resyn")
 @Produces(value="application/json")
void ResynConductors()

updateComposedIdentification

@POST
 @Path(value="/identification/{possibleGlobalID}")
 @Consumes(value="application/json")
 @Produces(value="application/json")
List<GlobalIdentification> updateComposedIdentification(LocalIdentification si,
                                                                                                                                                                                           @PathParam(value="possibleGlobalID")
                                                                                                                                                                                           String possibleGlobalID)

Update a identification to the identification database As the global ID is assign by SALSA, the possibleGlobalID is for the creation of new GlobalID

Parameters:

si -

possibleGlobalID -

Returns:

deleteGlobalIdentification

@DELETE
 @Path(value="/identification/{globalID}")
void deleteGlobalIdentification(@PathParam(value="globalID")
                                                                                   String globalID)

health

@GET
 @Path(value="/health")
String health()

cleanDB

@POST
 @Path(value="/clean")
String cleanDB()