Package step.functions.execution

Class FunctionExecutionServiceImpl

java.lang.Object

step.functions.execution.FunctionExecutionServiceImpl

All Implemented Interfaces:

FunctionExecutionService

public class FunctionExecutionServiceImpl
extends Object
implements FunctionExecutionService

Field Summary

Fields

Modifier and Type	Field	Description
static final String	INPUT_PROPERTY_CONTAINER_CMD
static final String	INPUT_PROPERTY_CONTAINER_USER
static final String	INPUT_PROPERTY_DOCKER_IMAGE
static final String	INPUT_PROPERTY_DOCKER_REGISTRY_PASSWORD
static final String	INPUT_PROPERTY_DOCKER_REGISTRY_URL
static final String	INPUT_PROPERTY_DOCKER_REGISTRY_USERNAME

Constructor Summary

Constructors

Constructor	Description
FunctionExecutionServiceImpl(step.grid.client.GridClient gridClient, FunctionTypeRegistry functionTypeRegistry, DynamicBeanResolver dynamicBeanResolver)

Method Summary

Modifier and Type	Method	Description
<IN, OUT> step.functions.io.Output<OUT>	callFunction(String tokenHandleId, Function function, FunctionInput<IN> functionInput, Class<OUT> outputClass)
protected Map<String,String>	fileVersionIdToMap(String propertyName, step.grid.filemanager.FileVersionId fileVersionId)
step.grid.TokenWrapper	getLocalTokenHandle()
step.grid.TokenWrapper	getTokenHandle(Map<String,String> attributes, Map<String,step.grid.tokenpool.Interest> interests, boolean createSession, step.grid.TokenWrapperOwner tokenWrapperOwner)
protected Map<String,String>	registerFile(File file, String properyName)
void	registerTokenLifecycleInterceptor(TokenLifecycleInterceptor interceptor)
void	returnTokenHandle(String tokenHandleId)
void	unregisterTokenLifecycleInterceptor(TokenLifecycleInterceptor interceptor)

Methods inherited from class java.lang.Object

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

Field Details

INPUT_PROPERTY_DOCKER_IMAGE

public static final String INPUT_PROPERTY_DOCKER_IMAGE

See Also:

• Constant Field Values

INPUT_PROPERTY_CONTAINER_USER

public static final String INPUT_PROPERTY_CONTAINER_USER

See Also:

• Constant Field Values

INPUT_PROPERTY_CONTAINER_CMD

public static final String INPUT_PROPERTY_CONTAINER_CMD

See Also:

• Constant Field Values

INPUT_PROPERTY_DOCKER_REGISTRY_URL

public static final String INPUT_PROPERTY_DOCKER_REGISTRY_URL

See Also:

• Constant Field Values

INPUT_PROPERTY_DOCKER_REGISTRY_USERNAME

public static final String INPUT_PROPERTY_DOCKER_REGISTRY_USERNAME

See Also:

• Constant Field Values

INPUT_PROPERTY_DOCKER_REGISTRY_PASSWORD

public static final String INPUT_PROPERTY_DOCKER_REGISTRY_PASSWORD

See Also:

• Constant Field Values

Constructor Details

FunctionExecutionServiceImpl

public FunctionExecutionServiceImpl(step.grid.client.GridClient gridClient,
 FunctionTypeRegistry functionTypeRegistry,
 DynamicBeanResolver dynamicBeanResolver)
                             throws FunctionExecutionServiceException

Throws:

FunctionExecutionServiceException

Method Details

registerTokenLifecycleInterceptor

public void registerTokenLifecycleInterceptor(TokenLifecycleInterceptor interceptor)

Specified by:

registerTokenLifecycleInterceptor in interface FunctionExecutionService

unregisterTokenLifecycleInterceptor

public void unregisterTokenLifecycleInterceptor(TokenLifecycleInterceptor interceptor)

Specified by:

unregisterTokenLifecycleInterceptor in interface FunctionExecutionService

getLocalTokenHandle

public step.grid.TokenWrapper getLocalTokenHandle()

Specified by:

getLocalTokenHandle in interface FunctionExecutionService

getTokenHandle

public step.grid.TokenWrapper getTokenHandle(Map<String,String> attributes,
 Map<String,step.grid.tokenpool.Interest> interests,
 boolean createSession,
 step.grid.TokenWrapperOwner tokenWrapperOwner)
                                      throws FunctionExecutionServiceException

Specified by:

getTokenHandle in interface FunctionExecutionService

Throws:

FunctionExecutionServiceException

returnTokenHandle

public void returnTokenHandle(String tokenHandleId)
                       throws FunctionExecutionServiceException

Specified by:

returnTokenHandle in interface FunctionExecutionService

Throws:

FunctionExecutionServiceException

callFunction

public <IN,
OUT> step.functions.io.Output<OUT> callFunction(String tokenHandleId,
 Function function,
 FunctionInput<IN> functionInput,
 Class<OUT> outputClass)

Specified by:

callFunction in interface FunctionExecutionService

registerFile

protected Map<String,String> registerFile(File file,
 String properyName)
                                   throws step.grid.filemanager.FileManagerException

Throws:

step.grid.filemanager.FileManagerException

fileVersionIdToMap

protected Map<String,String> fileVersionIdToMap(String propertyName,
 step.grid.filemanager.FileVersionId fileVersionId)