org.apache.ambari.server.mpack

Class MpackManager

java.lang.Object

org.apache.ambari.server.mpack.MpackManager

public class MpackManager
extends Object

Manages all mpack related behavior including parsing of stacks and providing access to mpack information.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<Long,Mpack>	mpackMap

Constructor Summary

Constructors

Constructor and Description
MpackManager(File mpacksStagingLocation, File stackRootDir, MpackDAO mpackDAOObj, StackDAO stackDAOObj)

Method Summary

Modifier and Type	Method and Description
Path	downloadMpack(String mpackURI, String mpackDefinitionLocation) Download the mpack from the given uri
List<Module>	getModules(Long mpackId) Fetches the mpack info stored in the memory for mpacks/{mpack_id} call.
Map<Long,Mpack>	getMpackMap()
protected Long	populateDB(Mpack mpacks) Make an entry in the mpacks database for the newly registered mpack.
protected void	populateStackDB(Mpack mpack) Makes an entry or updates the entry in the stack table to establish a link between the mpack and the associated stack
MpackResponse	registerMpack(MpackRequest mpackRequest) Parses mpack.json to fetch mpack and associated packlet information and stores the mpack to the database and mpackMap
boolean	removeMpack(MpackEntity mpackEntity, StackEntity stackEntity) Remove the mpack and stack directories when a request comes in to delete a particular mpack.
void	setMpackMap(Map<Long,Mpack> mpackMap)
protected boolean	validateMpackInfo(String expectedMpackName, String expectedMpackVersion, String actualMpackName, String actualMpackVersion) Compares if the user's mpack information matches the downloaded mpack information.

Methods inherited from class java.lang.Object

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

Field Detail

mpackMap

protected Map<Long,Mpack> mpackMap

Constructor Detail

MpackManager

public MpackManager(File mpacksStagingLocation,
                    File stackRootDir,
                    MpackDAO mpackDAOObj,
                    StackDAO stackDAOObj)

Method Detail

getMpackMap

public Map<Long,Mpack> getMpackMap()

setMpackMap

public void setMpackMap(Map<Long,Mpack> mpackMap)

registerMpack

public MpackResponse registerMpack(MpackRequest mpackRequest)
                            throws IOException,
                                   IllegalArgumentException,
                                   ResourceAlreadyExistsException

Parses mpack.json to fetch mpack and associated packlet information and stores the mpack to the database and mpackMap

Parameters:

mpackRequest -

Returns:

MpackResponse

Throws:

IOException

IllegalArgumentException

ResourceAlreadyExistsException

downloadMpack

public Path downloadMpack(String mpackURI,
                          String mpackDefinitionLocation)
                   throws IOException

Download the mpack from the given uri

Parameters:

mpackURI -

mpackDefinitionLocation -

Returns:

Throws:

IOException

validateMpackInfo

protected boolean validateMpackInfo(String expectedMpackName,
                                    String expectedMpackVersion,
                                    String actualMpackName,
                                    String actualMpackVersion)

Compares if the user's mpack information matches the downloaded mpack information.

Parameters:

expectedMpackName -

expectedMpackVersion -

actualMpackName -

actualMpackVersion -

Returns:

boolean

populateDB

protected Long populateDB(Mpack mpacks)
                   throws IOException

Make an entry in the mpacks database for the newly registered mpack.

Parameters:

mpacks -

Returns:

Throws:

IOException

populateStackDB

protected void populateStackDB(Mpack mpack)
                        throws IOException,
                               ResourceAlreadyExistsException

Makes an entry or updates the entry in the stack table to establish a link between the mpack and the associated stack

Parameters:

mpack -

Throws:

IOException

ResourceAlreadyExistsException

getModules

public List<Module> getModules(Long mpackId)

Fetches the mpack info stored in the memory for mpacks/{mpack_id} call.

Parameters:

mpackId -

Returns:

list of Module

removeMpack

public boolean removeMpack(MpackEntity mpackEntity,
                           StackEntity stackEntity)
                    throws IOException

Remove the mpack and stack directories when a request comes in to delete a particular mpack.

Parameters:

mpackEntity -

Throws:

IOException