Package org.gcube.vremanagement.executor.persistence

Class SmartExecutorPersistenceConnector

java.lang.Object

org.gcube.vremanagement.executor.plugin.PluginStateNotification

org.gcube.vremanagement.executor.persistence.SmartExecutorPersistenceConnector

All Implemented Interfaces:

ScheduledTaskPersistence

Direct Known Subclasses:

PostgreSQLPersistenceConnector

public abstract class SmartExecutorPersistenceConnector
extends org.gcube.vremanagement.executor.plugin.PluginStateNotification
implements ScheduledTaskPersistence

Model the connector which create or open the connection to DB.

Author:

Luca Frosini (ISTI - CNR)

Field Summary

Fields inherited from class org.gcube.vremanagement.executor.plugin.PluginStateNotification

inputs

Constructor Summary

Constructors

Constructor	Description
SmartExecutorPersistenceConnector()

Method Summary

Modifier and Type	Method	Description
abstract void	close()	Close the connection to DB
abstract Map<org.gcube.vremanagement.executor.plugin.PluginState,Long>	countFinalStates(Long since)	Counts the executions of the current Context that reached a final state, by that state: each execution of a Plugin records its final state once.
abstract long	deleteStatesBefore(long before)	Deletes the states of the executions of the current Context recorded before a time, except the last state of each task, so that the state of every task can still be read.
abstract org.gcube.vremanagement.executor.plugin.PluginStateEvolution	getPluginInstanceState(UUID uuid, Integer iterationNumber)	Retrieve the status of the iterationNumber (passed as parameter) of a running/run Plugin which is/was identified by the UUID passed as parameter

Methods inherited from class org.gcube.vremanagement.executor.plugin.PluginStateNotification

pluginStateEvolution

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gcube.vremanagement.executor.scheduledtask.ScheduledTaskPersistence

addScheduledTask, getScheduledTask, getScheduledTasks, releaseScheduledTask, releaseScheduledTask, removeScheduledTask, removeScheduledTask, reserveScheduledTask

Constructor Details

SmartExecutorPersistenceConnector

public SmartExecutorPersistenceConnector()

Method Details

close

public abstract void close()
                    throws Exception

Close the connection to DB

Throws:

Exception - if fails

getPluginInstanceState

public abstract org.gcube.vremanagement.executor.plugin.PluginStateEvolution getPluginInstanceState(UUID uuid,
 Integer iterationNumber)
                                                                                             throws org.gcube.vremanagement.executor.exception.PluginInstanceNotFoundException,
org.gcube.vremanagement.executor.exception.ExecutorException

Retrieve the status of the iterationNumber (passed as parameter) of a running/run Plugin which is/was identified by the UUID passed as parameter

Parameters:

uuid - the execution identifier of the running/run Plugin

iterationNumber - the iterationNumber (null to get the last)

Returns:

the actual/last PluginState of the Plugin

Throws:

org.gcube.vremanagement.executor.exception.PluginInstanceNotFoundException - if the plugin instance is not found

org.gcube.vremanagement.executor.exception.ExecutorException - if the operation fails

countFinalStates

public abstract Map<org.gcube.vremanagement.executor.plugin.PluginState,Long> countFinalStates(Long since)
                                                                                        throws org.gcube.vremanagement.executor.exception.ExecutorException

Counts the executions of the current Context that reached a final state, by that state: each execution of a Plugin records its final state once.

Parameters:

since - only the executions that reached their final state at this time or later, in milliseconds since the epoch; null counts all the executions in the database

Returns:

the number of executions by final state, with every final state present

Throws:

org.gcube.vremanagement.executor.exception.ExecutorException - if the operation fails

deleteStatesBefore

public abstract long deleteStatesBefore(long before)
                                 throws org.gcube.vremanagement.executor.exception.ExecutorException

Deletes the states of the executions of the current Context recorded before a time, except the last state of each task, so that the state of every task can still be read.

Parameters:

before - the time, in milliseconds since the epoch

Returns:

the number of states deleted

Throws:

org.gcube.vremanagement.executor.exception.ExecutorException - if the operation fails