com.netflix.nicobar.core.persistence

Class PathArchiveRepository

java.lang.Object

com.netflix.nicobar.core.persistence.PathArchiveRepository

All Implemented Interfaces:

ArchiveRepository

public class PathArchiveRepository
extends java.lang.Object
implements ArchiveRepository

ArchiveRepository implementation which stores ScriptArchives in sub-directories a root directory.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PathArchiveRepository.Builder
protected class	PathArchiveRepository.DefaultView

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.nio.file.DirectoryStream.Filter<java.nio.file.Path>	DIRECTORY_FILTER Directory filter which finds readable directories

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PathArchiveRepository(java.nio.file.Path rootDir, java.lang.String repositoryId, java.lang.String repositoryDescription, ScriptModuleSpecSerializer moduleSpecSerializer)

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteArchive(ModuleId moduleId) Delete an archive by ID
RepositoryView	getDefaultView() The default view reports all archives inserted into this repository.
java.lang.String	getRepositoryId() Get the ID of this repository
java.util.Set<ScriptArchive>	getScriptArchives(java.util.Set<ModuleId> moduleIds) Get all of the ScriptArchives for the given set of moduleIds.
RepositoryView	getView(java.lang.String view) No named views supported by this repository! Throws UnsupportedOperationException.
void	insertArchive(JarScriptArchive jarScriptArchive) Insert a Jar into the repository
void	insertArchive(JarScriptArchive jarScriptArchive, java.util.Map<java.lang.String,java.lang.Object> initialDeploySpecs) Unsupported.

Methods inherited from class java.lang.Object

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

Field Detail

DIRECTORY_FILTER

protected static final java.nio.file.DirectoryStream.Filter<java.nio.file.Path> DIRECTORY_FILTER

Directory filter which finds readable directories

Constructor Detail

PathArchiveRepository

protected PathArchiveRepository(java.nio.file.Path rootDir,
                     java.lang.String repositoryId,
                     java.lang.String repositoryDescription,
                     ScriptModuleSpecSerializer moduleSpecSerializer)

Method Detail

getRepositoryId

public java.lang.String getRepositoryId()

Description copied from interface: ArchiveRepository

Get the ID of this repository

Specified by:

getRepositoryId in interface ArchiveRepository

Returns:

the id string.

getDefaultView

public RepositoryView getDefaultView()

The default view reports all archives inserted into this repository.

Specified by:

getDefaultView in interface ArchiveRepository

Returns:

the default view into all archives.

getView

public RepositoryView getView(java.lang.String view)

No named views supported by this repository! Throws UnsupportedOperationException.

Specified by:

getView in interface ArchiveRepository

Parameters:

view - the name of the view.

Returns:

a RepositoryView that matches the given name or null if one wasn't found.

insertArchive

public void insertArchive(JarScriptArchive jarScriptArchive)
                   throws java.io.IOException

Description copied from interface: ArchiveRepository

Insert a Jar into the repository

Specified by:

insertArchive in interface ArchiveRepository

Parameters:

jarScriptArchive - script archive which describes the jar and the ModuleSpec which should be inserted

Throws:

java.io.IOException

insertArchive

public void insertArchive(JarScriptArchive jarScriptArchive,
                 java.util.Map<java.lang.String,java.lang.Object> initialDeploySpecs)
                   throws java.io.IOException

Unsupported.

Specified by:

insertArchive in interface ArchiveRepository

Parameters:

jarScriptArchive - script archive which describes the jar and the ModuleSpec which should be inserted

initialDeploySpecs - a set of initial deployment specs.

Throws:

java.io.IOException

getScriptArchives

public java.util.Set<ScriptArchive> getScriptArchives(java.util.Set<ModuleId> moduleIds)
                                               throws java.io.IOException

Description copied from interface: ArchiveRepository

Get all of the ScriptArchives for the given set of moduleIds.

Specified by:

getScriptArchives in interface ArchiveRepository

Parameters:

moduleIds - keys to search for

Returns:

set of ScriptArchives retrieved from the database

Throws:

java.io.IOException

deleteArchive

public void deleteArchive(ModuleId moduleId)
                   throws java.io.IOException

Description copied from interface: ArchiveRepository

Delete an archive by ID

Specified by:

deleteArchive in interface ArchiveRepository

Parameters:

moduleId - module id to delete

Throws:

java.io.IOException