fr.gouv.vitam.processing.distributor.rest

Class ProcessDistributorResource

java.lang.Object

fr.gouv.vitam.processing.distributor.rest.ProcessDistributorResource

@Path(value="/processing/v1/worker_family")
public class ProcessDistributorResource
extends Object

Process Distributor Resource implementation

Constructor Summary

Constructors

Constructor and Description
ProcessDistributorResource(IWorkerManager workerManager) Constructor

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	createWorkerFamily(javax.ws.rs.core.HttpHeaders headers, String idFamily, com.fasterxml.jackson.databind.JsonNode query) Add a new worker family
javax.ws.rs.core.Response	deleteFamilyWorkers(javax.ws.rs.core.HttpHeaders headers, String idFamily, com.fasterxml.jackson.databind.JsonNode query) Delete workers for a specific family
javax.ws.rs.core.Response	deleteWorkerFamily(javax.ws.rs.core.HttpHeaders headers, String idFamily, com.fasterxml.jackson.databind.JsonNode query) Delete a specific worker family
javax.ws.rs.core.Response	getFamilyWorkersList(javax.ws.rs.core.HttpHeaders headers, String idFamily) Get the list of workers for a specific family
javax.ws.rs.core.Response	getWorkerFamilies(javax.ws.rs.core.HttpHeaders headers) Get the list of worker families
javax.ws.rs.core.Response	getWorkerFamilyStatus(javax.ws.rs.core.HttpHeaders headers, String idFamily) Get the list of worker families
javax.ws.rs.core.Response	getWorkerStatus(javax.ws.rs.core.HttpHeaders headers, String idFamily, String idWorker) Get status of a specific worker
javax.ws.rs.core.Response	putWorkerFamilies(javax.ws.rs.core.HttpHeaders headers, com.fasterxml.jackson.databind.JsonNode query) Interact with worker families
javax.ws.rs.core.Response	registerWorker(javax.ws.rs.core.HttpHeaders headers, String idFamily, String idWorker, String workerInformation) Register a new worker
javax.ws.rs.core.Response	unregisterWorker(javax.ws.rs.core.HttpHeaders headers, String idFamily, String idWorker) Unregister a specific worker family
javax.ws.rs.core.Response	updateWorker(javax.ws.rs.core.HttpHeaders headers, String idFamily, String idWorker, com.fasterxml.jackson.databind.JsonNode query) Update a specific worker
javax.ws.rs.core.Response	updateWorkerFamily(javax.ws.rs.core.HttpHeaders headers, String idFamily, com.fasterxml.jackson.databind.JsonNode query) Update a specific worker family

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessDistributorResource

public ProcessDistributorResource(IWorkerManager workerManager)

Constructor

Parameters:

workerManager -

Method Detail

getWorkerFamilies

@GET
 @Produces(value="application/json")
public javax.ws.rs.core.Response getWorkerFamilies(@Context
                                                                                             javax.ws.rs.core.HttpHeaders headers)

Get the list of worker families

Parameters:

headers - http header

Returns:

Response NOT_IMPLEMENTED

putWorkerFamilies

@PUT
 @Produces(value="application/json")
 @Consumes(value="application/json")
public javax.ws.rs.core.Response putWorkerFamilies(@Context
                                                                                                                                  javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                  com.fasterxml.jackson.databind.JsonNode query)

Interact with worker families

Parameters:

headers - http header

query - the query

Returns:

Response NOT_IMPLEMENTED

getWorkerFamilyStatus

@Path(value="/{id_family}")
 @GET
 @Produces(value="application/json")
public javax.ws.rs.core.Response getWorkerFamilyStatus(@Context
                                                                                                                              javax.ws.rs.core.HttpHeaders headers,
                                                                                                                              @PathParam(value="id_family")
                                                                                                                              String idFamily)

Get the list of worker families

Parameters:

headers - http header

idFamily - the id of the family

Returns:

Response NOT_IMPLEMENTED

createWorkerFamily

@Path(value="/{id_family}")
 @POST
 @Produces(value="application/json")
 @Consumes(value="application/json")
public javax.ws.rs.core.Response createWorkerFamily(@Context
                                                                                                                                                                 javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                 @PathParam(value="id_family")
                                                                                                                                                                 String idFamily,
                                                                                                                                                                 com.fasterxml.jackson.databind.JsonNode query)

Add a new worker family

Parameters:

headers - http header

idFamily - the id of the family

query - the query describing the worker family to be created

Returns:

Response NOT_IMPLEMENTED

updateWorkerFamily

@Path(value="/{id_family}")
 @PUT
 @Produces(value="application/json")
 @Consumes(value="application/json")
public javax.ws.rs.core.Response updateWorkerFamily(@Context
                                                                                                                                                                javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                @PathParam(value="id_family")
                                                                                                                                                                String idFamily,
                                                                                                                                                                com.fasterxml.jackson.databind.JsonNode query)

Update a specific worker family

Parameters:

headers - http header

idFamily - the id of the family

query - the query describing the worker family to be updated

Returns:

Response NOT_IMPLEMENTED

deleteWorkerFamily

@Path(value="/{id_family}")
 @DELETE
 @Produces(value="application/json")
 @Consumes(value="application/json")
public javax.ws.rs.core.Response deleteWorkerFamily(@Context
                                                                                                                                                                   javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                   @PathParam(value="id_family")
                                                                                                                                                                   String idFamily,
                                                                                                                                                                   com.fasterxml.jackson.databind.JsonNode query)

Delete a specific worker family

Parameters:

headers - http header

idFamily - the id of the family

query - the query describing the worker family to be deleted

Returns:

Response NOT_IMPLEMENTED

getFamilyWorkersList

@Path(value="/{id_family}/workers")
 @GET
 @Produces(value="application/json")
public javax.ws.rs.core.Response getFamilyWorkersList(@Context
                                                                                                                                     javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                     @PathParam(value="id_family")
                                                                                                                                     String idFamily)

Get the list of workers for a specific family

Parameters:

headers - http header

idFamily - the id of the family

Returns:

Response NOT_IMPLEMENTED

deleteFamilyWorkers

@Path(value="/{id_family}/workers")
 @DELETE
 @Produces(value="application/json")
 @Consumes(value="application/json")
public javax.ws.rs.core.Response deleteFamilyWorkers(@Context
                                                                                                                                                                            javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                            @PathParam(value="id_family")
                                                                                                                                                                            String idFamily,
                                                                                                                                                                            com.fasterxml.jackson.databind.JsonNode query)

Delete workers for a specific family

Parameters:

headers - http header

idFamily - the id of the family

query - the query describing the workers to be deleted

Returns:

Response NOT_IMPLEMENTED

getWorkerStatus

@Path(value="/{id_family}/workers/{id_worker}")
 @GET
 @Produces(value="application/json")
public javax.ws.rs.core.Response getWorkerStatus(@Context
                                                                                                                                            javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                            @PathParam(value="id_family")
                                                                                                                                            String idFamily,
                                                                                                                                            @PathParam(value="id_worker")
                                                                                                                                            String idWorker)

Get status of a specific worker

Parameters:

headers - http header

idFamily - the id of the family

idWorker - the id of the worker

Returns:

Response NOT_IMPLEMENTED

registerWorker

@Path(value="/{id_family}/workers/{id_worker}")
 @POST
 @Produces(value="application/json")
 @Consumes(value="application/json")
public javax.ws.rs.core.Response registerWorker(@Context
                                                                                                                                                                                 javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                                 @PathParam(value="id_family")
                                                                                                                                                                                 String idFamily,
                                                                                                                                                                                 @PathParam(value="id_worker")
                                                                                                                                                                                 String idWorker,
                                                                                                                                                                                 String workerInformation)

Register a new worker

Parameters:

headers - http header

idFamily - the id of the family

idWorker - the id of the worker

workerInformation - information describing the worker to be registered

Returns:

Response the status of the registering

updateWorker

@Path(value="/{id_family}/workers/{id_worker}")
 @PUT
 @Produces(value="application/json")
 @Consumes(value="application/json")
public javax.ws.rs.core.Response updateWorker(@Context
                                                                                                                                                                              javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                                              @PathParam(value="id_family")
                                                                                                                                                                              String idFamily,
                                                                                                                                                                              @PathParam(value="id_worker")
                                                                                                                                                                              String idWorker,
                                                                                                                                                                              com.fasterxml.jackson.databind.JsonNode query)

Update a specific worker

Parameters:

headers - http header

idFamily - the id of the family

idWorker - the id of the worker

query - the query describing the worker to be updated

Returns:

Response NOT_IMPLEMENTED

unregisterWorker

@Path(value="/{id_family}/workers/{id_worker}")
 @DELETE
 @Produces(value="application/json")
public javax.ws.rs.core.Response unregisterWorker(@Context
                                                                                                                                                javax.ws.rs.core.HttpHeaders headers,
                                                                                                                                                @PathParam(value="id_family")
                                                                                                                                                String idFamily,
                                                                                                                                                @PathParam(value="id_worker")
                                                                                                                                                String idWorker)

Unregister a specific worker family

Parameters:

headers - http header

idFamily - the id of the family

idWorker - the id of the worker

Returns:

Response the status of the unregistering