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
static final String	ROLE	The Avalon role.

Constructor Summary

Constructors

Constructor	Description
PipelineManager()

Method Summary

Modifier and Type	Method	Description
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 Details

ROLE

public static final String ROLE

The Avalon role.

Constructor Details

PipelineManager

public PipelineManager()

Method Details

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

getDefaultPipeline

public String getDefaultPipeline()

Gets the id of the default PipelineDescriptor

Returns:

the id of the default PipelineDescriptor