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	returnTokenHandle(String tokenId)

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 Detail

RemoteFunctionExecutionService

public RemoteFunctionExecutionService(ControllerCredentials credentials)

RemoteFunctionExecutionService

public RemoteFunctionExecutionService()

Method Detail

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