Package cz.metacentrum.perun.core.bl

Interface TasksManagerBl

All Known Implementing Classes:
TasksManagerBlImpl
public interface TasksManagerBl
TasksManagerBl

  • Method Details

    • countTasks

      int countTasks()
      Get number of tasks in DB.
      Returns:
      int number of tasks

    • deleteAllTaskResults

      int deleteAllTaskResults(PerunSession sess)
      Delete all TaskResults
      Returns:
      number of deleted TaskResults

    • deleteOldTaskResults

      int deleteOldTaskResults(PerunSession sess, int numDays)
      Delete all TaskResults older than specified number of days
      Parameters:
      numDays - Number of days to keep
      Returns:
      number of deleted TaskResults

    • deleteTask

      void deleteTask(PerunSession sess, Task task)
      Delete Task and it's TaskResults. Use this method only before deleting whole Facility.
      Parameters:
      sess - PerunSession
      task - Task to delete
      Throws:
      InternalErrorException

    • deleteTaskResultById

      void deleteTaskResultById(PerunSession sess, int taskResultId)
      Delete TaskResults by its ID
      Parameters:
      taskResultId - ID of TaskResult to delete

    • deleteTaskResults

      int deleteTaskResults(PerunSession sess, int taskId)
      Delete all TaskResults for the particular Task
      Parameters:
      taskId - ID of Task to delete TaskResults
      Returns:
      number of deleted TaskResults

    • deleteTaskResults

      int deleteTaskResults(PerunSession sess, int taskId, int destinationId)
      Delete all TaskResults for the particular Task and Destination.
      Parameters:
      taskId - ID of Task to delete TaskResults
      destinationId - ID of Destination to delete TaskResults
      Returns:
      number of deleted TaskResults

    • getAllFacilitiesStates

      List<FacilityState> getAllFacilitiesStates(PerunSession session) throws FacilityNotExistsException
      Return propagation status of all facilities in Perun
      Parameters:
      session - PerunSession
      Returns:
      all facilities propagation statuses
      Throws:
      InternalErrorException
      FacilityNotExistsException

    • getAllFacilitiesStatesForVo

      List<FacilityState> getAllFacilitiesStatesForVo(PerunSession session, Vo vo) throws VoNotExistsException, FacilityNotExistsException
      Return propagation status of all facilities related to VO resources
      Parameters:
      session - PerunSession
      Returns:
      all facilities propagation statuses
      Throws:
      InternalErrorException
      FacilityNotExistsException
      VoNotExistsException

    • getFacilityServicesState

      List<ServiceState> getFacilityServicesState(PerunSession sess, Facility facility)
      Returns list of ServiceStates for given facility. It lists states for all services, which are currently assigned to the facility or has any Task related to this facility.

      So results are returned even when there was no previous propagation of such service or service is no longer assigned.

      Parameters:
      sess -
      facility -
      Returns:
      list of ServiceStates
      Throws:
      InternalErrorException

    • getFacilityState

      FacilityState getFacilityState(PerunSession session, Facility facility) throws FacilityNotExistsException
      Return propagation status of facility
      Parameters:
      session -
      facility -
      Returns:
      propagation status of facility
      Throws:
      FacilityNotExistsException
      InternalErrorException

    • getResourcesState

      List<ResourceState> getResourcesState(PerunSession session, Vo vo) throws VoNotExistsException
      Returns list of ResourceStates for VO.
      Parameters:
      session - PerunSession
      vo - VirtualOrganization
      Returns:
      list of ResourceStates
      Throws:
      VoNotExistsException
      InternalErrorException

    • getTask

      Task getTask(PerunSession perunSession, Service service, Facility facility)
      Find propagation task for given service and facility.
      Parameters:
      perunSession -
      service -
      facility -
      Returns:
      Task

    • getTaskById

      Task getTaskById(PerunSession perunSession, int id)
      Retrieve task given its id.
      Parameters:
      perunSession -
      id -
      Returns:
      Task

    • getTaskResultById

      TaskResult getTaskResultById(PerunSession sess, int taskResultId)
      Retrieve all task results for given task (by task id)
      Parameters:
      sess -
      taskResultId -
      Returns:
      TaskResult

    • getTaskResults

      List<TaskResult> getTaskResults(PerunSession sess)
      Retrieve all task results from DB.
      Parameters:
      sess -
      Returns:
      List of TaskResult

    • getTaskResultsByDestinations

      List<TaskResult> getTaskResultsByDestinations(PerunSession session, List<String> destinationsNames)
      Returns task results for defined destinations (string representation).
      Parameters:
      session -
      destinationsNames -
      Returns:
      list of tasks results

    • getTaskResultsByTask

      List<TaskResult> getTaskResultsByTask(PerunSession sess, int taskId)
      Retrieve all tasks results for given task
      Parameters:
      sess -
      taskId -
      Returns:
      List of TaskResult

    • getTaskResultsByTaskAndDestination

      List<TaskResult> getTaskResultsByTaskAndDestination(PerunSession sess, int taskId, int destinationId)
      List newest TaskResults tied to a certain task and destination
      Parameters:
      taskId -
      Returns:
      List of TaskResult

    • getTaskResultsByTaskOnlyNewest

      List<TaskResult> getTaskResultsByTaskOnlyNewest(PerunSession sess, int taskId)
      List newest TaskResults tied to a certain task
      Parameters:
      taskId -
      Returns:
      List of TaskResult

    • insertNewTaskResult

      int insertNewTaskResult(PerunSession sess, TaskResult taskResult)
      Insert TaskResult into DB.
      Parameters:
      sess -
      taskResult -
      Returns:
      int id of the new task result

    • insertTask

      int insertTask(PerunSession sess, Task task)
      Insert Task into DB.
      Parameters:
      sess -
      task -
      Returns:
      int id of the inserted task

    • isSuspendedTasksPropagation

      boolean isSuspendedTasksPropagation()
      Check if propagating tasks to engine is suspended.
      Returns:
      True if suspended, false if propagating

    • isSuspendedTasksPropagationPersistently

      boolean isSuspendedTasksPropagationPersistently()
      Check if propagating tasks to engine is suspended via the DB flag CAREFUL: even if not suspended though DB, can be disabled temporarily through synced field
      Returns:
      True if suspended in DB, false otherwise

    • isThereSuchTask

      boolean isThereSuchTask(PerunSession sess, Service service, Facility facility)
      Check if there is a task for given service and facility.
      Parameters:
      sess -
      service -
      facility -
      Returns:
      boolean true if there is a task, false otherwise

    • listAllTasks

      List<Task> listAllTasks(PerunSession perunSession)
      Retrieve all tasks from DB.
      Parameters:
      perunSession -
      Returns:
      List of Task

    • listAllTasksForFacility

      List<Task> listAllTasksForFacility(PerunSession session, int facilityId)
      Returns all tasks associated with selected facility.
      Parameters:
      session -
      facilityId -
      Returns:
      all tasks for facility

    • listAllTasksForService

      List<Task> listAllTasksForService(PerunSession sess, int serviceId)
      Returns all tasks associated with given service.
      Parameters:
      serviceId -
      Returns:
      tasks for service

    • listAllTasksInState

      List<Task> listAllTasksInState(PerunSession perunSession, Task.TaskStatus state)
      Retrieve all tasks in given state.
      Parameters:
      perunSession -
      state -
      Returns:
      List of Task

    • listAllTasksNotInState

      List<Task> listAllTasksNotInState(PerunSession sess, Task.TaskStatus state)
      Retrieve all tasks that are not in given state.
      Parameters:
      sess -
      state -
      Returns:
      List of Task

    • removeAllTasksForService

      void removeAllTasksForService(PerunSession sess, Service service)
      Removes all tasks associated with given service including the associated task results
      Parameters:
      service -

    • removeTask

      void removeTask(PerunSession sess, int id)
      Remove task with given id.
      Parameters:
      sess -
      id -

    • removeTask

      void removeTask(PerunSession sess, Service service, Facility facility)
      Remove task for given service and facility.
      Parameters:
      sess -
      service -
      facility -

    • suspendTasksPropagation

      void suspendTasksPropagation(PerunSession sess, boolean suspend, boolean persistently)
      Suspend propagating tasks to engine.
      Parameters:
      sess -
      suspend - True for suspending propagation, false for resuming propagation
      persistently - True for the change to persist even after Perun restart

    • updateTask

      void updateTask(PerunSession sess, Task task)
      Update DB record for given task.
      Parameters:
      sess -
      task -

    • retrieveRunIdForTask

      Task retrieveRunIdForTask(PerunSession sess, Task task)
      Retrieves a new run id for the task propagation.
      Parameters:
      sess - session
      task - task to schedule
      Returns:
      task with updated run id