Package step.controller.grid.services

Class AbtractFunctionServices

java.lang.Object

step.core.deployment.AbstractServices

step.controller.grid.services.AbtractFunctionServices

Direct Known Subclasses:

FunctionServices

public abstract class AbtractFunctionServices
extends AbstractServices

Field Summary

Fields

Modifier and Type	Field	Description
protected FunctionAccessor	functionAccessor
protected FunctionExecutionService	functionExecutionService
protected FunctionLocator	functionLocator
protected FunctionManager	functionManager
protected ReportNodeAttachmentManager	reportNodeAttachmentManager
protected SelectorHelper	selectorHelper

Fields inherited from class step.core.deployment.AbstractServices

configuration, controller

Constructor Summary

Constructors

Constructor	Description
AbtractFunctionServices()

Method Summary

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

Methods inherited from class step.core.deployment.AbstractServices

getContext, getExecutionRunnable, getObjectDrainer, getObjectEnricher, getScheduler, getSession, setSession

Methods inherited from class java.lang.Object

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

Field Detail

reportNodeAttachmentManager

protected ReportNodeAttachmentManager reportNodeAttachmentManager

functionAccessor

protected FunctionAccessor functionAccessor

functionManager

protected FunctionManager functionManager

functionExecutionService

protected FunctionExecutionService functionExecutionService

selectorHelper

protected SelectorHelper selectorHelper

functionLocator

protected FunctionLocator functionLocator

Constructor Detail

AbtractFunctionServices

public AbtractFunctionServices()

Method Detail

init

@PostConstruct
public void init()
          throws Exception

Overrides:

init in class AbstractServices

Throws:

Exception

getAll

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

get

@GET
@Path("/{id}")
@Produces("application/json")
public Function get(@PathParam("id")
                    String functionId)

get

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

findMany

@POST
@Path("/find")
@Produces("application/json")
public List<Function> findMany(Map<String,String> attributes)

lookupCallFunction

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

getFunctionEditor

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

save

@POST
@Consumes("application/json")
@Produces("application/json")
public Function save(Function function)
              throws SetupFunctionException,
                     FunctionTypeException

Throws:

SetupFunctionException

FunctionTypeException

copyFunction

@POST
@Path("/{id}/copy")
@Consumes("application/json")
@Produces("application/json")
public void copyFunction(@PathParam("id")
                         String id)
                  throws FunctionTypeException

Throws:

FunctionTypeException

delete

@DELETE
@Path("/{id}")
public void delete(@PathParam("id")
                   String functionId)
            throws FunctionTypeException

Throws:

FunctionTypeException

newFunctionTypeConf

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

getTokenHandle

@POST
@Produces("application/json")
@Path("/executor/tokens/select")
public step.grid.TokenWrapper getTokenHandle(GetTokenHandleParameter parameter,
                                             @Context
                                             javax.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

callFunction

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

callFunction

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