Package step.artefacts.handlers

Class DefaultFunctionRouterImpl

java.lang.Object

step.artefacts.handlers.DefaultFunctionRouterImpl

All Implemented Interfaces:

FunctionRouter

public class DefaultFunctionRouterImpl
extends Object
implements FunctionRouter

Field Summary

Fields

Modifier and Type	Field	Description
protected step.grid.tokenpool.SimpleAffinityEvaluator<step.grid.tokenpool.Identity,step.grid.tokenpool.Identity>	affinityEvaluator
protected FunctionExecutionService	functionExecutionService
protected FunctionTypeRegistry	functionTypeRegistry
protected TokenSelectorHelper	tokenSelectorHelper

Constructor Summary

Constructors

Constructor	Description
DefaultFunctionRouterImpl(FunctionExecutionService functionClient, FunctionTypeRegistry functionTypeRegistry, DynamicJsonObjectResolver dynamicJsonObjectResolver)

Method Summary

Modifier and Type	Method	Description
protected Map<String,step.grid.tokenpool.Interest>	buildSelectionCriteriaMap(CallFunction callFunction, Function function, FunctionGroupHandler.FunctionGroupContext functionGroupContext, Map<String,Object> bindings)
protected step.grid.tokenpool.Identity	identity(Map<String,step.grid.tokenpool.Interest> selectionCriteria, Map<String,String> attributes)
step.grid.TokenWrapper	selectToken(CallFunction callFunction, Function function, FunctionGroupHandler.FunctionGroupContext functionGroupContext, Map<String,Object> bindings, step.grid.TokenWrapperOwner tokenWrapperOwner)

Methods inherited from class java.lang.Object

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

Field Detail

tokenSelectorHelper

protected final TokenSelectorHelper tokenSelectorHelper

functionExecutionService

protected final FunctionExecutionService functionExecutionService

functionTypeRegistry

protected final FunctionTypeRegistry functionTypeRegistry

affinityEvaluator

protected final step.grid.tokenpool.SimpleAffinityEvaluator<step.grid.tokenpool.Identity,step.grid.tokenpool.Identity> affinityEvaluator

Constructor Detail

DefaultFunctionRouterImpl

public DefaultFunctionRouterImpl(FunctionExecutionService functionClient,
                                 FunctionTypeRegistry functionTypeRegistry,
                                 DynamicJsonObjectResolver dynamicJsonObjectResolver)

Method Detail

selectToken

public step.grid.TokenWrapper selectToken(CallFunction callFunction,
                                          Function function,
                                          FunctionGroupHandler.FunctionGroupContext functionGroupContext,
                                          Map<String,Object> bindings,
                                          step.grid.TokenWrapperOwner tokenWrapperOwner)
                                   throws FunctionExecutionServiceException

Specified by:

selectToken in interface FunctionRouter

Throws:

FunctionExecutionServiceException

identity

protected step.grid.tokenpool.Identity identity(Map<String,step.grid.tokenpool.Interest> selectionCriteria,
                                                Map<String,String> attributes)

buildSelectionCriteriaMap

protected Map<String,step.grid.tokenpool.Interest> buildSelectionCriteriaMap(CallFunction callFunction,
                                                                                   Function function,
                                                                                   FunctionGroupHandler.FunctionGroupContext functionGroupContext,
                                                                                   Map<String,Object> bindings)