Package step.controller.grid.services

Class AbtractFunctionServices

java.lang.Object

step.framework.server.AbstractServices<User>

step.core.deployment.AbstractStepServices

step.core.deployment.AbstractStepAsyncServices

step.controller.services.entities.AbstractEntityServices<Function>

step.controller.grid.services.AbtractFunctionServices

Direct Known Subclasses:

FunctionServices

public abstract class AbtractFunctionServices
extends AbstractEntityServices<Function>

Nested Class Summary

Nested classes/interfaces inherited from class step.controller.services.entities.AbstractEntityServices

AbstractEntityServices.History

Field Summary

Fields

Modifier and Type	Field	Description
protected FunctionAccessor	functionAccessor
protected FunctionExecutionService	functionExecutionService
protected FunctionLocator	functionLocator
protected FunctionManager	functionManager
protected step.core.objectenricher.ObjectPredicateFactory	objectPredicateFactory
protected ReportNodeAttachmentManager	reportNodeAttachmentManager
protected SelectorHelper	selectorHelper

Fields inherited from class step.core.deployment.AbstractStepServices

configuration, SESSION

Constructor Summary

Constructors

Constructor	Description
AbtractFunctionServices()

Method Summary

Modifier and Type	Method	Description
step.functions.io.Output<jakarta.json.JsonObject>	callFunctionByAttributes(String tokenId, FunctionInput<jakarta.json.JsonObject> input, jakarta.ws.rs.core.UriInfo uriInfo)
step.functions.io.Output<jakarta.json.JsonObject>	callFunctionById(String tokenId, String functionId, FunctionInput<jakarta.json.JsonObject> input)
Function	clone(String id)
void	delete(String functionId)
List<Function>	getAllFunctions(Integer skip, Integer limit)
String	getFunctionEditor(String functionId)
jakarta.json.JsonObject	getFunctionInputFromSchema(String functionId)
step.grid.TokenWrapper	getTokenHandle(GetTokenHandleParameter parameter, jakarta.servlet.http.HttpServletRequest req)
void	init()
Function	lookupCallFunction(CallFunction callFunction)
Function	newFunctionTypeConf(String type)
void	returnTokenHandle(String tokenId)
Function	save(Function function)
Function	searchFunction(Map<String,String> attributes)

Methods inherited from class step.controller.services.entities.AbstractEntityServices

beforeSave, bulkDelete, cloneEntities, cloneEntity, findManyByAttributes, get, getVersions, request, restoreVersion

Methods inherited from class step.core.deployment.AbstractStepAsyncServices

getSession, scheduleAsyncTaskWithinSessionContext, setCurrentSession

Methods inherited from class step.core.deployment.AbstractStepServices

checkRightsOnBehalfOf, getAuthorizationManager, getContext, getExecutionRunnable, getObjectEnricher, getObjectFilter, getScheduler

Methods inherited from class step.framework.server.AbstractServices

getAbstractContext, getHttpSession, getSession, invalidateSession, setHttpServletRequest, setSession

Methods inherited from class java.lang.Object

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

Field Details

reportNodeAttachmentManager

protected ReportNodeAttachmentManager reportNodeAttachmentManager

functionAccessor

protected FunctionAccessor functionAccessor

functionManager

protected FunctionManager functionManager

functionExecutionService

protected FunctionExecutionService functionExecutionService

selectorHelper

protected SelectorHelper selectorHelper

functionLocator

protected FunctionLocator functionLocator

objectPredicateFactory

protected step.core.objectenricher.ObjectPredicateFactory objectPredicateFactory

Constructor Details

AbtractFunctionServices

public AbtractFunctionServices()

Method Details

init

@PostConstruct
public void init()
          throws Exception

Overrides:

init in class AbstractEntityServices<Function>

Throws:

Exception

getAllFunctions

@GET
@Produces("application/json")
public List<Function> getAllFunctions(@QueryParam("skip")
 Integer skip,
 @QueryParam("limit")
 Integer limit)

searchFunction

@POST
@Path("/search")
@Consumes("application/json")
@Produces("application/json")
public Function searchFunction(Map<String,String> attributes)

lookupCallFunction

@POST
@Path("/lookup")
@Produces("application/json")
@Consumes("application/json")
public Function lookupCallFunction(CallFunction callFunction)

getFunctionEditor

@GET
@Produces("text/html")
@Path("/{id}/editor")
public String getFunctionEditor(@PathParam("id")
 String functionId)

getFunctionInputFromSchema

@GET
@Produces("application/json")
@Path("/{id}/schema/inputs")
public jakarta.json.JsonObject getFunctionInputFromSchema(@PathParam("id")
 String functionId)

save

public Function save(Function function)

Overrides:

save in class AbstractEntityServices<Function>

clone

public Function clone(String id)

Overrides:

clone in class AbstractEntityServices<Function>

delete

public void delete(String functionId)

Overrides:

delete in class AbstractEntityServices<Function>

newFunctionTypeConf

@GET
@Path("/types/{id}")
@Consumes("application/json")
@Produces("application/json")
public Function newFunctionTypeConf(@PathParam("id")
 String type)

getTokenHandle

@POST
@Produces("application/json")
@Consumes("application/json")
@Path("/executor/tokens/select")
public step.grid.TokenWrapper getTokenHandle(GetTokenHandleParameter parameter,
 @Context
 jakarta.servlet.http.HttpServletRequest req)
                                      throws FunctionExecutionServiceException

Throws:

FunctionExecutionServiceException

returnTokenHandle

@POST
@Produces("application/json")
@Path("/executor/tokens/{id}/return")
public void returnTokenHandle(@PathParam("id")
 String tokenId)
                       throws FunctionExecutionServiceException

Throws:

FunctionExecutionServiceException

callFunctionById

@POST
@Consumes("application/json")
@Produces("application/json")
@Path("/executor/tokens/{id}/execute/{functionId}")
public step.functions.io.Output<jakarta.json.JsonObject> callFunctionById(@PathParam("id")
 String tokenId,
 @PathParam("functionId")
 String functionId,
 FunctionInput<jakarta.json.JsonObject> input)

callFunctionByAttributes

@POST
@Produces("application/json")
@Consumes("application/json")
@Path("/executor/tokens/{id}/execute")
public step.functions.io.Output<jakarta.json.JsonObject> callFunctionByAttributes(@PathParam("id")
 String tokenId,
 FunctionInput<jakarta.json.JsonObject> input,
 @Context
 jakarta.ws.rs.core.UriInfo uriInfo)