Package step.functions.packages

Class FunctionPackageManager

java.lang.Object

step.functions.packages.FunctionPackageManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class FunctionPackageManager
extends Object
implements Closeable

This class is responsible for the handling of FunctionPackage It is responsible for the import of FunctionPackage. The import of a FunctionPackage means:

• the persistence of the FunctionPackage itself
• the definition of the Function contained in the package
• the registration of change watcher of the package file of the FunctionPackage

Constructor Summary

Constructors

Constructor	Description
FunctionPackageManager(FunctionPackageAccessor functionPackageAccessor, FunctionManager functionRepository, ResourceManager resourceManager, FileResolver fileResolver, ch.exense.commons.app.Configuration configuration, step.core.objectenricher.ObjectHookRegistry objectHookRegistry)

Method Summary

Modifier and Type	Method	Description
FunctionPackage	addOrUpdateFunctionPackage(FunctionPackage newFunctionPackage)	Adds or updates a FunctionPackage This triggers the import or re-import of the Functions contained in the package
void	close()
FunctionPackage	getFunctionPackage(String id)
List<Function>	getPackageFunctions(String functionPackageId)
List<Function>	getPackagePreview(FunctionPackage functionPackage)	Get the list of Function contained in the provided package
void	registerAttributeResolver(String key, Function<String,String> value)
void	registerFunctionPackageHandler(FunctionPackageHandler packageHandler)	Registers a FunctionPackageHandler
FunctionPackage	reloadFunctionPackage(String functionPackageId)	Reloads a FunctionPackage.
void	removeFunctionPackage(String id)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Details

FunctionPackageManager

public FunctionPackageManager(FunctionPackageAccessor functionPackageAccessor,
 FunctionManager functionRepository,
 ResourceManager resourceManager,
 FileResolver fileResolver,
 ch.exense.commons.app.Configuration configuration,
 step.core.objectenricher.ObjectHookRegistry objectHookRegistry)

Method Details

start

public void start()

registerFunctionPackageHandler

public void registerFunctionPackageHandler(FunctionPackageHandler packageHandler)

Registers a FunctionPackageHandler

Parameters:

packageHandler - the instance of the FunctionPackageHandler

registerAttributeResolver

public void registerAttributeResolver(String key,
 Function<String,String> value)

getPackagePreview

public List<Function> getPackagePreview(FunctionPackage functionPackage)
                                 throws Exception

Get the list of Function contained in the provided package

Parameters:

functionPackage - the FunctionPackage containing functions

Returns:

the list of Function found in the FunctionPackage

Throws:

Exception - if any error occurs during loading

addOrUpdateFunctionPackage

public FunctionPackage addOrUpdateFunctionPackage(FunctionPackage newFunctionPackage)
                                           throws Exception

Adds or updates a FunctionPackage This triggers the import or re-import of the Functions contained in the package

Parameters:

newFunctionPackage - the FunctionPackage to be loaded

Returns:

the updated FunctionPackage

Throws:

Exception - if any error occurs during loading

reloadFunctionPackage

public FunctionPackage reloadFunctionPackage(String functionPackageId)
                                      throws Exception

Reloads a FunctionPackage. This triggers a re-import of the Functions contained in the package

Parameters:

functionPackageId - the ID of the FunctionPackage to be reloaded

Returns:

the updated FunctionPackage

Throws:

Exception - if any error occurs during reloading

getFunctionPackage

public FunctionPackage getFunctionPackage(String id)

getPackageFunctions

public List<Function> getPackageFunctions(String functionPackageId)

removeFunctionPackage

public void removeFunctionPackage(String id)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException