com.netflix.genie.core.jpa.services

Class JpaClusterServiceImpl

java.lang.Object

com.netflix.genie.core.jpa.services.JpaClusterServiceImpl

All Implemented Interfaces:

ClusterService

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

Implementation of the ClusterService interface using JPA.

Constructor Summary

Constructors

Constructor and Description
JpaClusterServiceImpl(JpaClusterRepository clusterRepo, JpaCommandRepository commandRepo) Default constructor - initialize all required dependencies.

Method Summary

Modifier and Type	Method and Description
void	addCommandsForCluster(java.lang.String id, java.util.List<java.lang.String> commandIds) Add commands to the cluster.
void	addConfigsForCluster(java.lang.String id, java.util.Set<java.lang.String> configs) Add configuration files to the cluster.
void	addDependenciesForCluster(java.lang.String id, java.util.Set<java.lang.String> dependencies) Add dependency files to the cluster.
void	addTagsForCluster(java.lang.String id, java.util.Set<java.lang.String> tags) Add tags to the cluster.
java.util.List<Cluster>	chooseClusterForJobRequest(JobRequest jobRequest) Get the clusters on which the job can be run.
java.lang.String	createCluster(Cluster cluster) Create new cluster configuration.
void	deleteAllClusters() Delete all clusters from database.
void	deleteCluster(java.lang.String id) Delete a cluster configuration by id.
Cluster	getCluster(java.lang.String id) Get the cluster configuration by id.
org.springframework.data.domain.Page<Cluster>	getClusters(java.lang.String name, java.util.Set<ClusterStatus> statuses, java.util.Set<java.lang.String> tags, java.util.Date minUpdateTime, java.util.Date maxUpdateTime, org.springframework.data.domain.Pageable page) Get cluster info for various parameters.
java.util.List<Command>	getCommandsForCluster(java.lang.String id, java.util.Set<CommandStatus> statuses) Get the set of commands associated with the cluster with given id.
java.util.Set<java.lang.String>	getConfigsForCluster(java.lang.String id) Get the set of configuration files associated with the cluster with given id.
java.util.Set<java.lang.String>	getDependenciesForCluster(java.lang.String id) Get the set of dependency files associated with the cluster with given id.
java.util.Set<java.lang.String>	getTagsForCluster(java.lang.String id) Get the set of tags associated with the cluster with given id.
void	patchCluster(java.lang.String id, com.github.fge.jsonpatch.JsonPatch patch) Patch a cluster with the given json patch.
void	removeAllCommandsForCluster(java.lang.String id) Remove all commands from the cluster.
void	removeAllConfigsForCluster(java.lang.String id) Remove all configuration files from the cluster.
void	removeAllDependenciesForCluster(java.lang.String id) Remove all dependency files from the cluster.
void	removeAllTagsForCluster(java.lang.String id) Remove all tags from the cluster.
void	removeCommandForCluster(java.lang.String id, java.lang.String cmdId) Remove a command from the cluster.
void	removeDependencyForCluster(java.lang.String id, java.lang.String dependency) Remove a dependency file from the cluster.
void	removeTagForCluster(java.lang.String id, java.lang.String tag) Remove a tag from the cluster.
void	setCommandsForCluster(java.lang.String id, java.util.List<java.lang.String> commandIds) Update the set of command files associated with the cluster with given id.
void	updateCluster(java.lang.String id, Cluster updateCluster) Update a cluster.
void	updateConfigsForCluster(java.lang.String id, java.util.Set<java.lang.String> configs) Update the set of configuration files associated with the cluster with given id.
void	updateDependenciesForCluster(java.lang.String id, java.util.Set<java.lang.String> dependencies) Update the set of dependency files associated with the cluster with given id.
void	updateTagsForCluster(java.lang.String id, java.util.Set<java.lang.String> tags) Update the set of tags associated with the cluster with given id.

Methods inherited from class java.lang.Object

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

Constructor Detail

JpaClusterServiceImpl

public JpaClusterServiceImpl(JpaClusterRepository clusterRepo,
                             JpaCommandRepository commandRepo)

Default constructor - initialize all required dependencies.

Parameters:

clusterRepo - The cluster repository to use.

commandRepo - The command repository to use.

Method Detail

createCluster

public java.lang.String createCluster(@NotNull(message="No cluster entered. Unable to create.")
                                      Cluster cluster)
                               throws GenieException

Create new cluster configuration.

Specified by:

createCluster in interface ClusterService

Parameters:

cluster - The cluster to create

Returns:

The created clusters id

Throws:

GenieException - if there is an error

getCluster

@Transactional(readOnly=true)
public Cluster getCluster(@NotBlank(message="No id entered. Unable to get.")
                                                        java.lang.String id)
                                                 throws GenieException

Get the cluster configuration by id.

Specified by:

getCluster in interface ClusterService

Parameters:

id - unique id of cluster configuration to return

Returns:

The cluster configuration

Throws:

GenieException - For any error

getClusters

@Transactional(readOnly=true)
public org.springframework.data.domain.Page<Cluster> getClusters(java.lang.String name,
                                                                                               java.util.Set<ClusterStatus> statuses,
                                                                                               java.util.Set<java.lang.String> tags,
                                                                                               java.util.Date minUpdateTime,
                                                                                               java.util.Date maxUpdateTime,
                                                                                               org.springframework.data.domain.Pageable page)

Get cluster info for various parameters. Null or empty parameters are ignored.

Specified by:

getClusters in interface ClusterService

Parameters:

name - cluster name

statuses - valid types - Types.ClusterStatus

tags - tags allocated to this cluster

minUpdateTime - min time when cluster configuration was updated

maxUpdateTime - max time when cluster configuration was updated

page - The page to get

Returns:

All the clusters matching the criteria

chooseClusterForJobRequest

@Transactional(readOnly=true)
public java.util.List<Cluster> chooseClusterForJobRequest(@NotNull(message="JobRequest object is null. Unable to continue.")
                                                                                        JobRequest jobRequest)
                                                                                 throws GenieException

Get the clusters on which the job can be run.

Specified by:

chooseClusterForJobRequest in interface ClusterService

Parameters:

jobRequest - The request to runt he job. Not null.

Returns:

successful response, or one with HTTP error code

Throws:

GenieException - if there is an error

updateCluster

public void updateCluster(@NotBlank(message="No cluster id entered. Unable to update.")
                          java.lang.String id,
                          @NotNull(message="No cluster information entered. Unable to update.")
                          Cluster updateCluster)
                   throws GenieException

Update a cluster.

Specified by:

updateCluster in interface ClusterService

Parameters:

id - The id of the cluster to update

updateCluster - The information to update the cluster with

Throws:

GenieException - if there is an error

patchCluster

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

Patch a cluster with the given json patch.

Specified by:

patchCluster in interface ClusterService

Parameters:

id - The id of the cluster to update

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

Throws:

GenieException - if there is an error

deleteAllClusters

public void deleteAllClusters()
                       throws GenieException

Delete all clusters from database.

Specified by:

deleteAllClusters in interface ClusterService

Throws:

GenieException - if there is an error

deleteCluster

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

Delete a cluster configuration by id.

Specified by:

deleteCluster in interface ClusterService

Parameters:

id - unique id for cluster to delete

Throws:

GenieException - if there is an error

addConfigsForCluster

public void addConfigsForCluster(@NotBlank(message="No cluster 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 configuration files to the cluster.

Specified by:

addConfigsForCluster in interface ClusterService

Parameters:

id - The id of the cluster 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

getConfigsForCluster

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

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

Specified by:

getConfigsForCluster in interface ClusterService

Parameters:

id - The id of the cluster 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

updateConfigsForCluster

public void updateConfigsForCluster(@NotBlank(message="No cluster 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 cluster with given id.

Specified by:

updateConfigsForCluster in interface ClusterService

Parameters:

id - The id of the cluster 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

removeAllConfigsForCluster

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

Remove all configuration files from the cluster.

Specified by:

removeAllConfigsForCluster in interface ClusterService

Parameters:

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

Throws:

GenieException - if there is an error

addDependenciesForCluster

public void addDependenciesForCluster(@NotBlank(message="No cluster 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)
                               throws GenieException

Add dependency files to the cluster.

Specified by:

addDependenciesForCluster in interface ClusterService

Parameters:

id - The id of the cluster 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

getDependenciesForCluster

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

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

Specified by:

getDependenciesForCluster in interface ClusterService

Parameters:

id - The id of the cluster 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

updateDependenciesForCluster

public void updateDependenciesForCluster(@NotBlank(message="No cluster 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)
                                  throws GenieException

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

Specified by:

updateDependenciesForCluster in interface ClusterService

Parameters:

id - The id of the cluster 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

removeAllDependenciesForCluster

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

Remove all dependency files from the cluster.

Specified by:

removeAllDependenciesForCluster in interface ClusterService

Parameters:

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

Throws:

GenieException - if there is an error

removeDependencyForCluster

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

Remove a dependency file from the cluster.

Specified by:

removeDependencyForCluster in interface ClusterService

Parameters:

id - The id of the cluster 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

addTagsForCluster

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

Add tags to the cluster.

Specified by:

addTagsForCluster in interface ClusterService

Parameters:

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

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

Throws:

GenieException - if there is an error

getTagsForCluster

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

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

Specified by:

getTagsForCluster in interface ClusterService

Parameters:

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

Returns:

The set of tags as paths

Throws:

GenieException - if there is an error

updateTagsForCluster

public void updateTagsForCluster(@NotBlank(message="No cluster 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 cluster with given id.

Specified by:

updateTagsForCluster in interface ClusterService

Parameters:

id - The id of the cluster 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

removeAllTagsForCluster

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

Remove all tags from the cluster.

Specified by:

removeAllTagsForCluster in interface ClusterService

Parameters:

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

Throws:

GenieException - if there is an error

removeTagForCluster

public void removeTagForCluster(@NotBlank(message="No cluster 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 cluster.

Specified by:

removeTagForCluster in interface ClusterService

Parameters:

id - The id of the cluster 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

addCommandsForCluster

public void addCommandsForCluster(@NotBlank(message="No cluster id entered. Unable to add commands.")
                                  java.lang.String id,
                                  @NotEmpty(message="No command ids entered. Unable to add commands.")
                                  java.util.List<java.lang.String> commandIds)
                           throws GenieException

Add commands to the cluster.

Specified by:

addCommandsForCluster in interface ClusterService

Parameters:

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

commandIds - The ids of the commands to add. Not null/empty.

Throws:

GenieException - if there is an error

getCommandsForCluster

@Transactional(readOnly=true)
public java.util.List<Command> getCommandsForCluster(@NotBlank(message="No cluster id entered. Unable to get commands.")
                                                                                   java.lang.String id,
                                                                                   java.util.Set<CommandStatus> statuses)
                                                                            throws GenieException

Get the set of commands associated with the cluster with given id.

Specified by:

getCommandsForCluster in interface ClusterService

Parameters:

id - The id of the cluster to get the commands for. Not null/empty/blank.

statuses - The statuses to get commands for

Returns:

The list of commands

Throws:

GenieException - if there is an error

setCommandsForCluster

public void setCommandsForCluster(@NotBlank(message="No cluster id entered. Unable to update commands.")
                                  java.lang.String id,
                                  @NotNull(message="No command ids entered. Unable to update commands.")
                                  java.util.List<java.lang.String> commandIds)
                           throws GenieException

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

Specified by:

setCommandsForCluster in interface ClusterService

Parameters:

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

commandIds - The ids of the commands to replace existing commands with. Not null/empty.

Throws:

GenieException - if there is an error

removeAllCommandsForCluster

public void removeAllCommandsForCluster(@NotBlank(message="No cluster id entered. Unable to remove commands.")
                                        java.lang.String id)
                                 throws GenieException

Remove all commands from the cluster.

Specified by:

removeAllCommandsForCluster in interface ClusterService

Parameters:

id - The id of the cluster to remove the commands from. Not null/empty/blank.

Throws:

GenieException - if there is an error

removeCommandForCluster

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

Remove a command from the cluster.

Specified by:

removeCommandForCluster in interface ClusterService

Parameters:

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

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

Throws:

GenieException - if there is an error