Package org.ametys.plugins.extraction.execution.pipeline

Class PipelineManager

java.lang.Object

org.ametys.runtime.plugin.component.AbstractLogEnabled

org.ametys.plugins.extraction.execution.pipeline.PipelineManager

All Implemented Interfaces:

LogEnabled, Disposable, Initializable, Component, Serviceable

public class PipelineManager
extends AbstractLogEnabled
implements Component, Serviceable, Initializable, Disposable

Manager of PipelineDescriptors

Field Summary

Fields

Modifier and Type	Field	Description
private static String	__NO_OP_PIPELINE_ID
private Map<String,Long>	_lastReading
private PipelineDescriptor	_noOpPipelineDesc
private Map<String,PipelineDescriptor>	_pipelineDescCache
private SourceResolver	_resolver
private PipelineSerializerModelExtensionPoint	_serializerEP
static String	ROLE	The Avalon role.

Constructor Summary

Constructors

Constructor	Description
PipelineManager()

Method Summary

Modifier and Type	Method	Description
private Path	_absolutePath(String relativePath)
private List<Map<String,Object>>	_getJsonEnumeration(String extractionId)
private String	_getPipelineIdFromAbsolutePath(Path pipelineAbsolutePath)
private static Long	_now()
private void	_readAll()
private PipelineDescriptor	_readAndGetPipeline(String path)
private Stream<Pair<String,PipelineDescriptor>>	_readFromFile(Path path)
private Stream<Pair<String,PipelineDescriptor>>	_readFromFolder(Path folderPath)
private Pair<String,PipelineDescriptor>	_readPipeline(Path pipelinePath)
void	dispose()
PipelineDescriptor	get(String path)	Gets the PipelineDescriptor for the given path
PipelineDescriptor	get(Path path)	Gets the PipelineDescriptor for the given path
Map<String,Object>	getAvailablePipelines(String extractionId)	Gets the available pipelines for the given extraction
String	getDefaultPipeline()	Gets the id of the default PipelineDescriptor
boolean	has(String path)	Returns true if the PipelineDescriptor for asked path exists
void	initialize()
void	service(ServiceManager manager)

Methods inherited from class org.ametys.runtime.plugin.component.AbstractLogEnabled

getLogger, setLogger

Methods inherited from class java.lang.Object

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

Field Detail

ROLE

public static final String ROLE

The Avalon role.

__NO_OP_PIPELINE_ID

private static final String __NO_OP_PIPELINE_ID

_noOpPipelineDesc

private PipelineDescriptor _noOpPipelineDesc

_pipelineDescCache

private Map<String,PipelineDescriptor> _pipelineDescCache

_lastReading

private Map<String,Long> _lastReading

_resolver

private SourceResolver _resolver

_serializerEP

private PipelineSerializerModelExtensionPoint _serializerEP

Constructor Detail

PipelineManager

public PipelineManager()

Method Detail

service

public void service(ServiceManager manager)
             throws ServiceException

Specified by:

service in interface Serviceable

Throws:

ServiceException

initialize

public void initialize()
                throws Exception

Specified by:

initialize in interface Initializable

Throws:

Exception

dispose

public void dispose()

Specified by:

dispose in interface Disposable

has

public boolean has(String path)
            throws IOException

Returns true if the PipelineDescriptor for asked path exists

Parameters:

path - The path of the PipelineDescriptor

Returns:

true if the asked pipeline exists

Throws:

IOException - if an I/O exception occurred when accessing the root folder of pipeline files

get

public PipelineDescriptor get(Path path)
                       throws IOException

Gets the PipelineDescriptor for the given path

Parameters:

path - The path of the pipeline

Returns:

the request PipelineDescriptor, or null if not found

Throws:

IOException - if an I/O exception occurred when accessing the root folder of pipeline files

get

public PipelineDescriptor get(String path)
                       throws IOException

Gets the PipelineDescriptor for the given path

Parameters:

path - The path of the pipeline

Returns:

the request PipelineDescriptor, or null if not found

Throws:

IOException - if an I/O exception occurred when accessing the root folder of pipeline files

getAvailablePipelines

public Map<String,Object> getAvailablePipelines(String extractionId)
                                               throws IOException

Gets the available pipelines for the given extraction

Parameters:

extractionId - the extraction's definition file name

Returns:

the available pipelines

Throws:

IOException - if an I/O exception occurred when accessing the root folder of pipeline files

_getJsonEnumeration

private List<Map<String,Object>> _getJsonEnumeration(String extractionId)
                                                    throws IOException

Throws:

IOException

getDefaultPipeline

public String getDefaultPipeline()

Gets the id of the default PipelineDescriptor

Returns:

the id of the default PipelineDescriptor

_readAndGetPipeline

private PipelineDescriptor _readAndGetPipeline(String path)
                                        throws IOException

Throws:

IOException

_readAll

private void _readAll()
               throws IOException

Throws:

IOException

_absolutePath

private Path _absolutePath(String relativePath)
                    throws IOException

Throws:

IOException

_readFromFolder

private Stream<Pair<String,PipelineDescriptor>> _readFromFolder(Path folderPath)
                                                               throws IOException

Throws:

IOException

_readFromFile

private Stream<Pair<String,PipelineDescriptor>> _readFromFile(Path path)
                                                             throws IOException

Throws:

IOException

_readPipeline

private Pair<String,PipelineDescriptor> _readPipeline(Path pipelinePath)
                                                     throws IOException

Throws:

IOException

_getPipelineIdFromAbsolutePath

private String _getPipelineIdFromAbsolutePath(Path pipelineAbsolutePath)
                                       throws IOException

Throws:

IOException

_now

private static Long _now()