Package fr.gouv.vitam.processing.distributor.rest

Class ProcessDistributorResource

  • @Path("/processing/v1/worker_family")
public class ProcessDistributorResource
extends java.lang.Object
    Process Distributor Resource implementation

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      javax.ws.rs.core.Response createWorkerFamily​(javax.ws.rs.core.HttpHeaders headers, java.lang.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, java.lang.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, java.lang.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, java.lang.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, java.lang.String idFamily)
      Get the list of worker families
      javax.ws.rs.core.Response getWorkerStatus​(javax.ws.rs.core.HttpHeaders headers, java.lang.String idFamily, java.lang.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, java.lang.String idFamily, java.lang.String idWorker, WorkerBean workerInformation)
      Register a new worker
      javax.ws.rs.core.Response unregisterWorker​(javax.ws.rs.core.HttpHeaders headers, java.lang.String idFamily, java.lang.String idWorker)
      Unregister a specific worker family
      javax.ws.rs.core.Response updateWorker​(javax.ws.rs.core.HttpHeaders headers, java.lang.String idFamily, java.lang.String idWorker, com.fasterxml.jackson.databind.JsonNode query)
      Update a specific worker
      javax.ws.rs.core.Response updateWorkerFamily​(javax.ws.rs.core.HttpHeaders headers, java.lang.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("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("application/json")
@Consumes("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("/{id_family}")
@GET
@Produces("application/json")
public javax.ws.rs.core.Response getWorkerFamilyStatus​(@Context
                                                       javax.ws.rs.core.HttpHeaders headers,
                                                       @PathParam("id_family")
                                                       java.lang.String idFamily)
        Get the list of worker families
        Parameters:
        headers - http header
        idFamily - the id of the family
        Returns:
        Response NOT_IMPLEMENTED

      • createWorkerFamily

        @Path("/{id_family}")
@POST
@Produces("application/json")
@Consumes("application/json")
public javax.ws.rs.core.Response createWorkerFamily​(@Context
                                                    javax.ws.rs.core.HttpHeaders headers,
                                                    @PathParam("id_family")
                                                    java.lang.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("/{id_family}")
@PUT
@Produces("application/json")
@Consumes("application/json")
public javax.ws.rs.core.Response updateWorkerFamily​(@Context
                                                    javax.ws.rs.core.HttpHeaders headers,
                                                    @PathParam("id_family")
                                                    java.lang.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("/{id_family}")
@DELETE
@Produces("application/json")
@Consumes("application/json")
public javax.ws.rs.core.Response deleteWorkerFamily​(@Context
                                                    javax.ws.rs.core.HttpHeaders headers,
                                                    @PathParam("id_family")
                                                    java.lang.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("/{id_family}/workers")
@GET
@Produces("application/json")
public javax.ws.rs.core.Response getFamilyWorkersList​(@Context
                                                      javax.ws.rs.core.HttpHeaders headers,
                                                      @PathParam("id_family")
                                                      java.lang.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("/{id_family}/workers")
@DELETE
@Produces("application/json")
@Consumes("application/json")
public javax.ws.rs.core.Response deleteFamilyWorkers​(@Context
                                                     javax.ws.rs.core.HttpHeaders headers,
                                                     @PathParam("id_family")
                                                     java.lang.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("/{id_family}/workers/{id_worker}")
@GET
@Produces("application/json")
public javax.ws.rs.core.Response getWorkerStatus​(@Context
                                                 javax.ws.rs.core.HttpHeaders headers,
                                                 @PathParam("id_family")
                                                 java.lang.String idFamily,
                                                 @PathParam("id_worker")
                                                 java.lang.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("/{id_family}/workers/{id_worker}")
@POST
@Produces("application/json")
@Consumes("application/json")
public javax.ws.rs.core.Response registerWorker​(@Context
                                                javax.ws.rs.core.HttpHeaders headers,
                                                @PathParam("id_family")
                                                java.lang.String idFamily,
                                                @PathParam("id_worker")
                                                java.lang.String idWorker,
                                                WorkerBean 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("/{id_family}/workers/{id_worker}")
@PUT
@Produces("application/json")
@Consumes("application/json")
public javax.ws.rs.core.Response updateWorker​(@Context
                                              javax.ws.rs.core.HttpHeaders headers,
                                              @PathParam("id_family")
                                              java.lang.String idFamily,
                                              @PathParam("id_worker")
                                              java.lang.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("/{id_family}/workers/{id_worker}")
@DELETE
@Produces("application/json")
public javax.ws.rs.core.Response unregisterWorker​(@Context
                                                  javax.ws.rs.core.HttpHeaders headers,
                                                  @PathParam("id_family")
                                                  java.lang.String idFamily,
                                                  @PathParam("id_worker")
                                                  java.lang.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