com.netflix.genie.core.jpa.services

Class JpaCommandServiceImpl

java.lang.Object

com.netflix.genie.core.jpa.services.JpaCommandServiceImpl

All Implemented Interfaces:

CommandService

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

Implementation of the CommandService interface.

Since:

2.0.0

Constructor Summary

Constructors

Constructor and Description
JpaCommandServiceImpl(JpaCommandRepository commandRepo, JpaApplicationRepository appRepo, JpaClusterRepository clusterRepo) Default constructor.

Method Summary

Modifier and Type	Method and Description
void	addApplicationsForCommand(java.lang.String id, java.util.List<java.lang.String> applicationIds) Add applications for the command.
void	addConfigsForCommand(java.lang.String id, java.util.Set<java.lang.String> configs) Add a configuration files to the command.
void	addTagsForCommand(java.lang.String id, java.util.Set<java.lang.String> tags) Add tags to the command.
java.lang.String	createCommand(Command command) Create new command configuration.
void	deleteAllCommands() Delete all commands from database.
void	deleteCommand(java.lang.String id) Delete a command configuration from database.
java.util.List<Application>	getApplicationsForCommand(java.lang.String id) Get the applications for a given command.
java.util.Set<Cluster>	getClustersForCommand(java.lang.String id, java.util.Set<ClusterStatus> statuses) Get all the clusters the command with given id is associated with.
Command	getCommand(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(java.lang.String id) Get the set of configuration files associated with the command with given id.
java.util.Set<java.lang.String>	getTagsForCommand(java.lang.String id) Get the set of tags associated with the command with given id.
void	patchCommand(java.lang.String id, com.github.fge.jsonpatch.JsonPatch patch) Patch a command with the given json patch.
void	removeAllConfigsForCommand(java.lang.String id) Remove all configuration files from the command.
void	removeAllTagsForCommand(java.lang.String id) Remove all tags from the command.
void	removeApplicationForCommand(java.lang.String id, java.lang.String appId) Remove the application from the command.
void	removeApplicationsForCommand(java.lang.String id) Remove the applications from the command.
void	removeConfigForCommand(java.lang.String id, java.lang.String config) Remove a configuration file from the command.
void	removeTagForCommand(java.lang.String id, java.lang.String tag) Remove a tag from the command.
void	setApplicationsForCommand(java.lang.String id, java.util.List<java.lang.String> applicationIds) Set the applications for the command.
void	updateCommand(java.lang.String id, Command updateCommand) Update command configuration.
void	updateConfigsForCommand(java.lang.String id, java.util.Set<java.lang.String> configs) Update the set of configuration files associated with the command with given id.
void	updateTagsForCommand(java.lang.String id, 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

JpaCommandServiceImpl

public JpaCommandServiceImpl(JpaCommandRepository commandRepo,
                             JpaApplicationRepository appRepo,
                             JpaClusterRepository clusterRepo)

Default constructor.

Parameters:

commandRepo - the command repository to use

appRepo - the application repository to use

clusterRepo - the cluster repository to use

Method Detail

createCommand

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

Create new command configuration.

Specified by:

createCommand in interface CommandService

Parameters:

command - 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.")
                                                        java.lang.String id)
                                                 throws GenieException

Gets command configuration for given id.

Specified by:

getCommand in interface CommandService

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(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.

Specified by:

getCommands in interface CommandService

Parameters:

name - Name of command config

user - The name of the user who created the configuration

statuses - The status of the applications 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.")
                          java.lang.String id,
                          @NotNull(message="No command information entered. Unable to update.")
                          Command updateCommand)
                   throws GenieException

Update command configuration.

Specified by:

updateCommand in interface CommandService

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
                         java.lang.String id,
                         @NotNull
                         com.github.fge.jsonpatch.JsonPatch patch)
                  throws GenieException

Patch a command with the given json patch.

Specified by:

patchCommand in interface CommandService

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 CommandService

Throws:

GenieException - if there is an error

deleteCommand

public void deleteCommand(@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 CommandService

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.")
                                 java.lang.String id,
                                 @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 CommandService

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.")
                                                                                          java.lang.String id)
                                                                                   throws GenieException

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

Specified by:

getConfigsForCommand in interface CommandService

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.")
                                    java.lang.String id,
                                    @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 CommandService

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.")
                                       java.lang.String id)
                                throws GenieException

Remove all configuration files from the command.

Specified by:

removeAllConfigsForCommand in interface CommandService

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.")
                                   java.lang.String id,
                                   @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 CommandService

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

addTagsForCommand

public 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)
                       throws GenieException

Add tags to the command.

Specified by:

addTagsForCommand in interface CommandService

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.")
                                                                                       java.lang.String id)
                                                                                throws GenieException

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

Specified by:

getTagsForCommand in interface CommandService

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.")
                                 java.lang.String id,
                                 @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 CommandService

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.")
                                    java.lang.String id)
                             throws GenieException

Remove all tags from the command.

Specified by:

removeAllTagsForCommand in interface CommandService

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.")
                                java.lang.String id,
                                @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 CommandService

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.")
                                      java.lang.String id,
                                      @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 CommandService

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.")
                                      java.lang.String id,
                                      @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 CommandService

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.")
                                                                                           java.lang.String id)
                                                                                    throws GenieException

Get the applications for a given command.

Specified by:

getApplicationsForCommand in interface CommandService

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.")
                                         java.lang.String id)
                                  throws GenieException

Remove the applications from the command.

Specified by:

removeApplicationsForCommand in interface CommandService

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.")
                                        java.lang.String id,
                                        @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 CommandService

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.")
                                                                                  java.lang.String id,
                                                                                  java.util.Set<ClusterStatus> statuses)
                                                                           throws GenieException

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

Specified by:

getClustersForCommand in interface CommandService

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