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 final step.grid.tokenpool.SimpleAffinityEvaluator<step.grid.tokenpool.Identity,step.grid.tokenpool.Identity>	affinityEvaluator
protected final FunctionExecutionService	functionExecutionService
protected final FunctionTypeRegistry	functionTypeRegistry
protected final 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 Details

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 Details

DefaultFunctionRouterImpl

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

Method Details

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)