com.netflix.genie.web.data.services.jpa

Class JpaCommandPersistenceServiceImpl

java.lang.Object

com.netflix.genie.web.data.services.jpa.JpaCommandPersistenceServiceImpl

All Implemented Interfaces:

CommandPersistenceService

@Transactional(rollbackFor={GenieException.class,GenieRuntimeException.class,javax.validation.ConstraintViolationException.class})
public class JpaCommandPersistenceServiceImpl
extends java.lang.Object
implements CommandPersistenceService

Implementation of the CommandPersistenceService interface.

Since:

2.0.0

Constructor Summary

Constructors

Constructor and Description
JpaCommandPersistenceServiceImpl(JpaTagPersistenceService tagPersistenceService, JpaFilePersistenceService filePersistenceService, JpaApplicationRepository applicationRepository, JpaClusterRepository clusterRepository, JpaCommandRepository commandRepository, JpaCriterionRepository criterionRepository) Default constructor.

Method Summary

Modifier and Type	Method and Description
void	addApplicationsForCommand(@NotBlank(message="No command id entered. Unable to add applications.") java.lang.String id, @NotEmpty(message="No application ids entered. Unable to add applications.") java.util.List<java.lang.String> applicationIds) Add applications for the command.
void	addClusterCriterionForCommand(java.lang.String id, @Valid Criterion criterion) Add a new Criterion to the existing list of cluster criteria for the command identified by id.
void	addClusterCriterionForCommand(java.lang.String id, @Valid Criterion criterion, @Min(value=0L) int priority) Add a new Criterion to the existing list of cluster criteria for the command identified by id.
void	addConfigsForCommand(@NotBlank(message="No command id entered. Unable to add configurations.") java.lang.String id, @NotEmpty(message="No configuration files entered. Unable to add.") java.util.Set<java.lang.String> configs) Add a configuration files to the command.
void	addDependenciesForCommand(@NotBlank(message="No command id entered. Unable to add dependencies.") java.lang.String id, @NotEmpty(message="No dependencies entered. Unable to add dependencies.") java.util.Set<java.lang.String> dependencies) Add dependency files to the command.
void	addTagsForCommand(@NotBlank(message="No command id entered. Unable to add tags.") java.lang.String id, @NotEmpty(message="No tags entered. Unable to add.") java.util.Set<java.lang.String> tags) Add tags to the command.
java.lang.String	createCommand(@NotNull(message="No command entered. Unable to create.") @Valid CommandRequest request) Create new command configuration.
void	deleteAllCommands() Delete all commands from database.
void	deleteCommand(@NotBlank(message="No id entered. Unable to delete.") java.lang.String id) Delete a command configuration from database.
long	deleteUnusedCommands(java.util.Set<CommandStatus> deleteStatuses, java.time.Instant commandCreatedThreshold) Bulk delete commands from the database where their status is in deleteStatuses they were created before commandCreatedThreshold and they aren't attached to any jobs still in the database.
java.util.Set<Command>	findCommandsMatchingCriterion(@Valid Criterion criterion, boolean addDefaultStatus) Find all the Command's that match the given Criterion.
java.util.List<Application>	getApplicationsForCommand(@NotBlank(message="No command id entered. Unable to get applications.") java.lang.String id) Get the applications for a given command.
java.util.List<Criterion>	getClusterCriteriaForCommand(java.lang.String id) For the given command id return the Cluster Criterion in priority order that is currently associated with this command if any.
java.util.Set<Cluster>	getClustersForCommand(@NotBlank(message="No command id entered. Unable to get clusters.") java.lang.String id, java.util.Set<ClusterStatus> statuses) Get all the clusters the command with given id is associated with.
Command	getCommand(@NotBlank(message="No id entered unable to get.") java.lang.String id) Gets command configuration for given id.
org.springframework.data.domain.Page<Command>	getCommands(java.lang.String name, java.lang.String user, java.util.Set<CommandStatus> statuses, java.util.Set<java.lang.String> tags, org.springframework.data.domain.Pageable page) Get command configurations for given filter criteria.
java.util.Set<java.lang.String>	getConfigsForCommand(@NotBlank(message="No command id entered. Unable to get configs.") java.lang.String id) Get the set of configuration files associated with the command with given id.
java.util.Set<java.lang.String>	getDependenciesForCommand(@NotBlank(message="No command id entered. Unable to get dependencies.") java.lang.String id) Get the set of dependency files associated with the command with given id.
java.util.Set<java.lang.String>	getTagsForCommand(@NotBlank(message="No command id sent. Cannot retrieve tags.") java.lang.String id) Get the set of tags associated with the command with given id.
void	patchCommand(@NotBlank java.lang.String id, @NotNull com.github.fge.jsonpatch.JsonPatch patch) Patch a command with the given json patch.
void	removeAllClusterCriteriaForCommand(java.lang.String id) Remove all the Criterion currently associated with the command identified by id.
void	removeAllConfigsForCommand(@NotBlank(message="No command id entered. Unable to remove configs.") java.lang.String id) Remove all configuration files from the command.
void	removeAllDependenciesForCommand(@NotBlank(message="No command id entered. Unable to remove dependencies.") java.lang.String id) Remove all dependency files from the command.
void	removeAllTagsForCommand(@NotBlank(message="No command id entered. Unable to remove tags.") java.lang.String id) Remove all tags from the command.
void	removeApplicationForCommand(@NotBlank(message="No command id entered. Unable to remove application.") java.lang.String id, @NotBlank(message="No application id entered. Unable to remove application.") java.lang.String appId) Remove the application from the command.
void	removeApplicationsForCommand(@NotBlank(message="No command id entered. Unable to remove applications.") java.lang.String id) Remove the applications from the command.
void	removeClusterCriterionForCommand(java.lang.String id, @Min(value=0L) int priority) Remove the Criterion with the given priority from the current list of cluster criteria associated with the command identified by id.
void	removeConfigForCommand(@NotBlank(message="No command id entered. Unable to remove configuration.") java.lang.String id, @NotBlank(message="No config entered. Unable to remove.") java.lang.String config) Remove a configuration file from the command.
void	removeDependencyForCommand(@NotBlank(message="No command id entered. Unable to remove dependency.") java.lang.String id, @NotBlank(message="No dependency entered. Unable to remove dependency.") java.lang.String dependency) Remove a dependency file from the command.
void	removeTagForCommand(@NotBlank(message="No command id entered. Unable to remove tag.") java.lang.String id, @NotBlank(message="No tag entered. Unable to remove.") java.lang.String tag) Remove a tag from the command.
void	setApplicationsForCommand(@NotBlank(message="No command id entered. Unable to set applications.") java.lang.String id, @NotNull(message="No application ids entered. Unable to set applications.") java.util.List<java.lang.String> applicationIds) Set the applications for the command.
void	setClusterCriteriaForCommand(java.lang.String id, java.util.List<Criterion> clusterCriteria) For the command identified by id reset the entire list of cluster criteria to match the contents of clusterCriteria.
void	updateCommand(@NotBlank(message="No id entered. Unable to update.") java.lang.String id, @NotNull(message="No command information entered. Unable to update.") @Valid Command updateCommand) Update command configuration.
void	updateConfigsForCommand(@NotBlank(message="No command id entered. Unable to update configurations.") java.lang.String id, @NotEmpty(message="No configs entered. Unable to update.") java.util.Set<java.lang.String> configs) Update the set of configuration files associated with the command with given id.
void	updateDependenciesForCommand(@NotBlank(message="No command id entered. Unable to update dependencies.") java.lang.String id, @NotNull(message="No dependencies entered. Unable to update.") java.util.Set<java.lang.String> dependencies) Update the set of dependency files associated with the command with given id.
int	updateStatusForUnusedCommands(CommandStatus desiredStatus, java.time.Instant commandCreatedThreshold, java.util.Set<CommandStatus> currentStatuses, java.time.Instant jobCreatedThreshold) Update the status of a command to the desiredStatus if its status is in currentStatuses, it was created before commandCreatedThreshold and it hasn't been used in any job that was created in the Genie system after jobCreatedThreshold.
void	updateTagsForCommand(@NotBlank(message="No command id entered. Unable to update tags.") java.lang.String id, @NotEmpty(message="No tags entered. Unable to update.") java.util.Set<java.lang.String> tags) Update the set of tags associated with the command with given id.

Methods inherited from class java.lang.Object

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

Constructor Detail

JpaCommandPersistenceServiceImpl

public JpaCommandPersistenceServiceImpl(JpaTagPersistenceService tagPersistenceService,
                                        JpaFilePersistenceService filePersistenceService,
                                        JpaApplicationRepository applicationRepository,
                                        JpaClusterRepository clusterRepository,
                                        JpaCommandRepository commandRepository,
                                        JpaCriterionRepository criterionRepository)

Default constructor.

Parameters:

tagPersistenceService - The JpaTagPersistenceService to use

filePersistenceService - The JpaFilePersistenceService to use

applicationRepository - The JpaApplicationRepository to use

clusterRepository - The JpaClusterRepository to use

commandRepository - The JpaCommandRepository to use

criterionRepository - The JpaCriterionRepository to use

Method Detail

createCommand

public java.lang.String createCommand(@NotNull(message="No command entered. Unable to create.") @Valid
                                      @NotNull(message="No command entered. Unable to create.") @Valid CommandRequest request)
                               throws GenieException

Create new command configuration.

Specified by:

createCommand in interface CommandPersistenceService

Parameters:

request - encapsulates the command configuration information to create. Not null. Valid.

Returns:

The id of the command created

Throws:

GenieException - if there is an error

getCommand

@Transactional(readOnly=true)
public Command getCommand(@NotBlank(message="No id entered unable to get.")
                                                        @NotBlank(message="No id entered unable to get.") java.lang.String id)
                                                 throws GenieException

Gets command configuration for given id.

Specified by:

getCommand in interface CommandPersistenceService

Parameters:

id - unique id for command configuration to get. Not null/empty.

Returns:

The command configuration

Throws:

GenieException - if there is an error

getCommands

@Transactional(readOnly=true)
public org.springframework.data.domain.Page<Command> getCommands(@Nullable
                                                                                               java.lang.String name,
                                                                                               @Nullable
                                                                                               java.lang.String user,
                                                                                               @Nullable
                                                                                               java.util.Set<CommandStatus> statuses,
                                                                                               @Nullable
                                                                                               java.util.Set<java.lang.String> tags,
                                                                                               org.springframework.data.domain.Pageable page)

Get command configurations for given filter criteria.

Specified by:

getCommands in interface CommandPersistenceService

Parameters:

name - Name of command config

user - The name of the user who created the configuration

statuses - The status of the commands to get. Can be null.

tags - tags allocated to this command

page - The page of results to get

Returns:

All the commands matching the specified criteria

updateCommand

public void updateCommand(@NotBlank(message="No id entered. Unable to update.")
                          @NotBlank(message="No id entered. Unable to update.") java.lang.String id,
                          @NotNull(message="No command information entered. Unable to update.") @Valid
                          @NotNull(message="No command information entered. Unable to update.") @Valid Command updateCommand)
                   throws GenieException

Update command configuration.

Specified by:

updateCommand in interface CommandPersistenceService

Parameters:

id - The id of the command configuration to update. Not null or empty.

updateCommand - contains the information to update the command with

Throws:

GenieException - if there is an error

patchCommand

public void patchCommand(@NotBlank
                         @NotBlank java.lang.String id,
                         @NotNull
                         @NotNull com.github.fge.jsonpatch.JsonPatch patch)
                  throws GenieException

Patch a command with the given json patch.

Specified by:

patchCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to update

patch - The json patch to use to update the given command

Throws:

GenieException - if there is an error

deleteAllCommands

public void deleteAllCommands()
                       throws GenieException

Delete all commands from database.

Specified by:

deleteAllCommands in interface CommandPersistenceService

Throws:

GenieException - if there is an error

deleteCommand

public void deleteCommand(@NotBlank(message="No id entered. Unable to delete.")
                          @NotBlank(message="No id entered. Unable to delete.") java.lang.String id)
                   throws GenieException

Delete a command configuration from database.

Specified by:

deleteCommand in interface CommandPersistenceService

Parameters:

id - unique if of the command configuration to delete

Throws:

GenieException - if there is an error

addConfigsForCommand

public void addConfigsForCommand(@NotBlank(message="No command id entered. Unable to add configurations.")
                                 @NotBlank(message="No command id entered. Unable to add configurations.") java.lang.String id,
                                 @NotEmpty(message="No configuration files entered. Unable to add.")
                                 @NotEmpty(message="No configuration files entered. Unable to add.") java.util.Set<java.lang.String> configs)
                          throws GenieException

Add a configuration files to the command.

Specified by:

addConfigsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to add the configuration file to. Not null/empty/blank.

configs - The configuration files to add. Not null/empty.

Throws:

GenieException - if there is an error

getConfigsForCommand

@Transactional(readOnly=true)
public java.util.Set<java.lang.String> getConfigsForCommand(@NotBlank(message="No command id entered. Unable to get configs.")
                                                                                          @NotBlank(message="No command id entered. Unable to get configs.") java.lang.String id)
                                                                                   throws GenieException

Get the set of configuration files associated with the command with given id.

Specified by:

getConfigsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to get the configuration files for. Not null/empty/blank.

Returns:

The set of configuration files as paths

Throws:

GenieException - if there is an error

updateConfigsForCommand

public void updateConfigsForCommand(@NotBlank(message="No command id entered. Unable to update configurations.")
                                    @NotBlank(message="No command id entered. Unable to update configurations.") java.lang.String id,
                                    @NotEmpty(message="No configs entered. Unable to update.")
                                    @NotEmpty(message="No configs entered. Unable to update.") java.util.Set<java.lang.String> configs)
                             throws GenieException

Update the set of configuration files associated with the command with given id.

Specified by:

updateConfigsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to update the configuration files for. Not null/empty/blank.

configs - The configuration files to replace existing configurations with. Not null/empty.

Throws:

GenieException - if there is an error

removeAllConfigsForCommand

public void removeAllConfigsForCommand(@NotBlank(message="No command id entered. Unable to remove configs.")
                                       @NotBlank(message="No command id entered. Unable to remove configs.") java.lang.String id)
                                throws GenieException

Remove all configuration files from the command.

Specified by:

removeAllConfigsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the configuration file from. Not null/empty/blank.

Throws:

GenieException - if there is an error

removeConfigForCommand

public void removeConfigForCommand(@NotBlank(message="No command id entered. Unable to remove configuration.")
                                   @NotBlank(message="No command id entered. Unable to remove configuration.") java.lang.String id,
                                   @NotBlank(message="No config entered. Unable to remove.")
                                   @NotBlank(message="No config entered. Unable to remove.") java.lang.String config)
                            throws GenieException

Remove a configuration file from the command.

Specified by:

removeConfigForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the configuration file from. Not null/empty/blank.

config - The configuration file to remove. Not null/empty/blank.

Throws:

GenieException - if there is an error

addDependenciesForCommand

public void addDependenciesForCommand(@NotBlank(message="No command id entered. Unable to add dependencies.")
                                      @NotBlank(message="No command id entered. Unable to add dependencies.") java.lang.String id,
                                      @NotEmpty(message="No dependencies entered. Unable to add dependencies.")
                                      @NotEmpty(message="No dependencies entered. Unable to add dependencies.") java.util.Set<java.lang.String> dependencies)
                               throws GenieException

Add dependency files to the command.

Specified by:

addDependenciesForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to add the dependency file to. Not null/empty/blank.

dependencies - The dependency files to add. Not null.

Throws:

GenieException - if there is an error

getDependenciesForCommand

@Transactional(readOnly=true)
public java.util.Set<java.lang.String> getDependenciesForCommand(@NotBlank(message="No command id entered. Unable to get dependencies.")
                                                                                               @NotBlank(message="No command id entered. Unable to get dependencies.") java.lang.String id)
                                                                                        throws GenieException

Get the set of dependency files associated with the command with given id.

Specified by:

getDependenciesForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to get the dependency files for. Not null/empty/blank.

Returns:

The set of dependency files as paths

Throws:

GenieException - if there is an error

updateDependenciesForCommand

public void updateDependenciesForCommand(@NotBlank(message="No command id entered. Unable to update dependencies.")
                                         @NotBlank(message="No command id entered. Unable to update dependencies.") java.lang.String id,
                                         @NotNull(message="No dependencies entered. Unable to update.")
                                         @NotNull(message="No dependencies entered. Unable to update.") java.util.Set<java.lang.String> dependencies)
                                  throws GenieException

Update the set of dependency files associated with the command with given id.

Specified by:

updateDependenciesForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to update the dependency files for. Not null/empty/blank.

dependencies - The dependency files to replace existing dependencies with. Not null/empty.

Throws:

GenieException - if there is an error

removeAllDependenciesForCommand

public void removeAllDependenciesForCommand(@NotBlank(message="No command id entered. Unable to remove dependencies.")
                                            @NotBlank(message="No command id entered. Unable to remove dependencies.") java.lang.String id)
                                     throws GenieException

Remove all dependency files from the command.

Specified by:

removeAllDependenciesForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the configuration file from. Not null/empty/blank.

Throws:

GenieException - if there is an error

removeDependencyForCommand

public void removeDependencyForCommand(@NotBlank(message="No command id entered. Unable to remove dependency.")
                                       @NotBlank(message="No command id entered. Unable to remove dependency.") java.lang.String id,
                                       @NotBlank(message="No dependency entered. Unable to remove dependency.")
                                       @NotBlank(message="No dependency entered. Unable to remove dependency.") java.lang.String dependency)
                                throws GenieException

Remove a dependency file from the command.

Specified by:

removeDependencyForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the dependency file from. Not null/empty/blank.

dependency - The dependency file to remove. Not null/empty/blank.

Throws:

GenieException - if there is an error

addTagsForCommand

public void addTagsForCommand(@NotBlank(message="No command id entered. Unable to add tags.")
                              @NotBlank(message="No command id entered. Unable to add tags.") java.lang.String id,
                              @NotEmpty(message="No tags entered. Unable to add.")
                              @NotEmpty(message="No tags entered. Unable to add.") java.util.Set<java.lang.String> tags)
                       throws GenieException

Add tags to the command.

Specified by:

addTagsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to add the tags to. Not null/empty/blank.

tags - The tags to add. Not null/empty.

Throws:

GenieException - if there is an error

getTagsForCommand

@Transactional(readOnly=true)
public java.util.Set<java.lang.String> getTagsForCommand(@NotBlank(message="No command id sent. Cannot retrieve tags.")
                                                                                       @NotBlank(message="No command id sent. Cannot retrieve tags.") java.lang.String id)
                                                                                throws GenieException

Get the set of tags associated with the command with given id.

Specified by:

getTagsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to get the tags for. Not null/empty/blank.

Returns:

The set of tags as paths

Throws:

GenieException - if there is an error

updateTagsForCommand

public void updateTagsForCommand(@NotBlank(message="No command id entered. Unable to update tags.")
                                 @NotBlank(message="No command id entered. Unable to update tags.") java.lang.String id,
                                 @NotEmpty(message="No tags entered. Unable to update.")
                                 @NotEmpty(message="No tags entered. Unable to update.") java.util.Set<java.lang.String> tags)
                          throws GenieException

Update the set of tags associated with the command with given id.

Specified by:

updateTagsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to update the tags for. Not null/empty/blank.

tags - The tags to replace existing tags with. Not null/empty.

Throws:

GenieException - if there is an error

removeAllTagsForCommand

public void removeAllTagsForCommand(@NotBlank(message="No command id entered. Unable to remove tags.")
                                    @NotBlank(message="No command id entered. Unable to remove tags.") java.lang.String id)
                             throws GenieException

Remove all tags from the command.

Specified by:

removeAllTagsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the tags from. Not null/empty/blank.

Throws:

GenieException - if there is an error

removeTagForCommand

public void removeTagForCommand(@NotBlank(message="No command id entered. Unable to remove tag.")
                                @NotBlank(message="No command id entered. Unable to remove tag.") java.lang.String id,
                                @NotBlank(message="No tag entered. Unable to remove.")
                                @NotBlank(message="No tag entered. Unable to remove.") java.lang.String tag)
                         throws GenieException

Remove a tag from the command.

Specified by:

removeTagForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the tag from. Not null/empty/blank.

tag - The tag to remove. Not null/empty/blank.

Throws:

GenieException - if there is an error

addApplicationsForCommand

public void addApplicationsForCommand(@NotBlank(message="No command id entered. Unable to add applications.")
                                      @NotBlank(message="No command id entered. Unable to add applications.") java.lang.String id,
                                      @NotEmpty(message="No application ids entered. Unable to add applications.")
                                      @NotEmpty(message="No application ids entered. Unable to add applications.") java.util.List<java.lang.String> applicationIds)
                               throws GenieException

Add applications for the command.

Specified by:

addApplicationsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to add the application file to. Not null/empty/blank.

applicationIds - The ids of the applications to add. Not null.

Throws:

GenieException - if there is an error

setApplicationsForCommand

public void setApplicationsForCommand(@NotBlank(message="No command id entered. Unable to set applications.")
                                      @NotBlank(message="No command id entered. Unable to set applications.") java.lang.String id,
                                      @NotNull(message="No application ids entered. Unable to set applications.")
                                      @NotNull(message="No application ids entered. Unable to set applications.") java.util.List<java.lang.String> applicationIds)
                               throws GenieException

Set the applications for the command.

Specified by:

setApplicationsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to add the application file to. Not null/empty/blank.

applicationIds - The ids of the applications to set. Not null.

Throws:

GenieException - if there is an error

getApplicationsForCommand

@Transactional(readOnly=true)
public java.util.List<Application> getApplicationsForCommand(@NotBlank(message="No command id entered. Unable to get applications.")
                                                                                           @NotBlank(message="No command id entered. Unable to get applications.") java.lang.String id)
                                                                                    throws GenieException

Get the applications for a given command.

Specified by:

getApplicationsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to get the application for. Not null/empty/blank.

Returns:

The applications or exception if none exist.

Throws:

GenieException - if there is an error

removeApplicationsForCommand

public void removeApplicationsForCommand(@NotBlank(message="No command id entered. Unable to remove applications.")
                                         @NotBlank(message="No command id entered. Unable to remove applications.") java.lang.String id)
                                  throws GenieException

Remove the applications from the command.

Specified by:

removeApplicationsForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the application from. Not null/empty/blank.

Throws:

GenieException - if there is an error

removeApplicationForCommand

public void removeApplicationForCommand(@NotBlank(message="No command id entered. Unable to remove application.")
                                        @NotBlank(message="No command id entered. Unable to remove application.") java.lang.String id,
                                        @NotBlank(message="No application id entered. Unable to remove application.")
                                        @NotBlank(message="No application id entered. Unable to remove application.") java.lang.String appId)
                                 throws GenieException

Remove the application from the command.

Specified by:

removeApplicationForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the application from. Not null/empty/blank.

appId - The id of the application to remove. Not null/empty/blank

Throws:

GenieException - if there is an error

getClustersForCommand

@Transactional(readOnly=true)
public java.util.Set<Cluster> getClustersForCommand(@NotBlank(message="No command id entered. Unable to get clusters.")
                                                                                  @NotBlank(message="No command id entered. Unable to get clusters.") java.lang.String id,
                                                                                  @Nullable
                                                                                  java.util.Set<ClusterStatus> statuses)
                                                                           throws GenieException

Get all the clusters the command with given id is associated with.

Specified by:

getClustersForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to get the clusters for.

statuses - The status of the clusters returned

Returns:

The clusters the command is available on.

Throws:

GenieException - if there is an error

getClusterCriteriaForCommand

@Transactional(readOnly=true)
public java.util.List<Criterion> getClusterCriteriaForCommand(java.lang.String id)
                                                                                     throws GenieNotFoundException

For the given command id return the Cluster Criterion in priority order that is currently associated with this command if any.

Specified by:

getClusterCriteriaForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to get the criteria for

Returns:

The cluster criteria in priority order

Throws:

GenieNotFoundException - If no command with id exists

addClusterCriterionForCommand

public void addClusterCriterionForCommand(java.lang.String id,
                                          @Valid
                                          @Valid Criterion criterion)
                                   throws GenieNotFoundException

Add a new Criterion to the existing list of cluster criteria for the command identified by id. This new criterion will be the lowest priority criterion.

Specified by:

addClusterCriterionForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to add to

criterion - The new Criterion to add

Throws:

GenieNotFoundException - If no command with id exists

addClusterCriterionForCommand

public void addClusterCriterionForCommand(java.lang.String id,
                                          @Valid
                                          @Valid Criterion criterion,
                                          @Min(value=0L)
                                          @Min(value=0L) int priority)
                                   throws GenieNotFoundException

Add a new Criterion to the existing list of cluster criteria for the command identified by id. The priority is the place in the list this new criterion should be placed. A value of 0 indicates it should be placed at the front of the list with the highest possible priority. 1 would be second in the list etc. If priority is > the current size of the cluster criteria list this new criterion will be placed at the end as the lowest priority item.

Specified by:

addClusterCriterionForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to add to

criterion - The new Criterion to add

priority - The place in the existing cluster criteria list this new criterion should be placed. Min 0.

Throws:

GenieNotFoundException - If no command with id exists

setClusterCriteriaForCommand

public void setClusterCriteriaForCommand(java.lang.String id,
                                         java.util.List<Criterion> clusterCriteria)
                                  throws GenieNotFoundException

For the command identified by id reset the entire list of cluster criteria to match the contents of clusterCriteria.

Specified by:

setClusterCriteriaForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to set the cluster criteria for

clusterCriteria - The priority list of Criterion to set

Throws:

GenieNotFoundException - If no command with id exists

removeClusterCriterionForCommand

public void removeClusterCriterionForCommand(java.lang.String id,
                                             @Min(value=0L)
                                             @Min(value=0L) int priority)
                                      throws GenieNotFoundException

Remove the Criterion with the given priority from the current list of cluster criteria associated with the command identified by id. A value of 0 for priority will result in the first element in the list being removed, 1 the second element and so on.

Specified by:

removeClusterCriterionForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the criterion from

priority - The priority of the criterion to remove

Throws:

GenieNotFoundException - If no command with id exists

removeAllClusterCriteriaForCommand

public void removeAllClusterCriteriaForCommand(java.lang.String id)
                                        throws GenieNotFoundException

Remove all the Criterion currently associated with the command identified by id.

Specified by:

removeAllClusterCriteriaForCommand in interface CommandPersistenceService

Parameters:

id - The id of the command to remove the criteria from

Throws:

GenieNotFoundException - If no command with id exists

findCommandsMatchingCriterion

@Transactional(readOnly=true)
public java.util.Set<Command> findCommandsMatchingCriterion(@Valid
                                                                                          @Valid Criterion criterion,
                                                                                          boolean addDefaultStatus)

Find all the Command's that match the given Criterion.

Specified by:

findCommandsMatchingCriterion in interface CommandPersistenceService

Parameters:

criterion - The Criterion supplied that each command needs to completely match to be returned

addDefaultStatus - true if a default status should be added to the supplied criterion if a status isn't already present

Returns:

All the Command's which matched the Criterion

updateStatusForUnusedCommands

@Transactional(isolation=READ_COMMITTED)
public int updateStatusForUnusedCommands(CommandStatus desiredStatus,
                                                                                  java.time.Instant commandCreatedThreshold,
                                                                                  java.util.Set<CommandStatus> currentStatuses,
                                                                                  java.time.Instant jobCreatedThreshold)

Update the status of a command to the desiredStatus if its status is in currentStatuses, it was created before commandCreatedThreshold and it hasn't been used in any job that was created in the Genie system after jobCreatedThreshold.

Specified by:

updateStatusForUnusedCommands in interface CommandPersistenceService

Parameters:

desiredStatus - The new status the matching commands should have

commandCreatedThreshold - The instant in time which a command must have been created before to be considered for update. Exclusive

currentStatuses - The set of current statuses a command must have to be considered for update

jobCreatedThreshold - The instant in time after which a command must not have been used in a Genie job for it to be considered for update. Inclusive.

Returns:

The number of commands whose statuses were updated to desiredStatus

deleteUnusedCommands

@Transactional(isolation=READ_COMMITTED)
public long deleteUnusedCommands(java.util.Set<CommandStatus> deleteStatuses,
                                                                          java.time.Instant commandCreatedThreshold)

Bulk delete commands from the database where their status is in deleteStatuses they were created before commandCreatedThreshold and they aren't attached to any jobs still in the database.

Specified by:

deleteUnusedCommands in interface CommandPersistenceService

Parameters:

deleteStatuses - The set of statuses a command must be in in order to be considered for deletion

commandCreatedThreshold - The instant in time a command must have been created before to be considered for deletion. Exclusive.

Returns:

The number of commands that were deleted