Package step.client.functions

Class RemoteFunctionExecutionService

java.lang.Object

step.client.AbstractRemoteClient

step.client.functions.RemoteFunctionExecutionService

All Implemented Interfaces:

Closeable, AutoCloseable, FunctionExecutionService

public class RemoteFunctionExecutionService
extends AbstractRemoteClient
implements FunctionExecutionService

Field Summary

Fields inherited from class step.client.AbstractRemoteClient

client, cookies, credentials

Constructor Summary

Constructors

Constructor	Description
RemoteFunctionExecutionService()
RemoteFunctionExecutionService(ControllerCredentials credentials)

Method Summary

Modifier and Type	Method	Description
<IN, OUT> step.functions.io.Output<OUT>	callFunction(String tokenId, Function function, FunctionInput<IN> input, Class<OUT> outputClass)
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)
void	registerTokenLifecycleInterceptor(TokenLifecycleInterceptor interceptor)
void	returnTokenHandle(String tokenId)
void	unregisterTokenLifecycleInterceptor(TokenLifecycleInterceptor interceptor)

Methods inherited from class step.client.AbstractRemoteClient

close, executeRequest, notImplemented, requestBuilder, requestBuilder

Methods inherited from class java.lang.Object

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

Constructor Details

RemoteFunctionExecutionService

public RemoteFunctionExecutionService(ControllerCredentials credentials)

RemoteFunctionExecutionService

public RemoteFunctionExecutionService()

Method Details

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)

Specified by:

getTokenHandle in interface FunctionExecutionService

returnTokenHandle

public void returnTokenHandle(String tokenId)

Specified by:

returnTokenHandle in interface FunctionExecutionService

callFunction

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

Specified by:

callFunction in interface FunctionExecutionService

registerTokenLifecycleInterceptor

public void registerTokenLifecycleInterceptor(TokenLifecycleInterceptor interceptor)

Specified by:

registerTokenLifecycleInterceptor in interface FunctionExecutionService

unregisterTokenLifecycleInterceptor

public void unregisterTokenLifecycleInterceptor(TokenLifecycleInterceptor interceptor)

Specified by:

unregisterTokenLifecycleInterceptor in interface FunctionExecutionService