FaaS

How hard can it be to create a FaaS framework in Java?

to build

mvn clean package

to run

java -jar target/faas-XXX.war

faas's People

Contributors

Watchers

faas's Issues

Create the persistence

Create multi-threaded executor

public V execute(ExecutionResource<V> resource) {
	
	// probably best to submit this to a thread pool, such as a Scheduled Executor
	
	Function<V> function = resource.getFunction();
	JobRequest jobRequest = resource.getPreparedDescriptor().getJob().getJobRequest();
	function.setRequest(jobRequest);
	return function.call();
}

Create a gateway

Converts REST calls to put JSON messages on the queue to be consumed by Reactor
Presumably a GET call using a URL which identifies the function to call, with the params specified as URL params

http://myserver:8080/faasgw/functions/myFunction?vehicle=car&engine=hybrid

Should be a Spring Boot web app
The GW should include its routing key in the JobRequest object that it serialises to JSON
The GW should bind to the response broker on Rabbit, binding an exclusive queue (only exists whilst connected, deleted when GW disconnects, only accessible to this instance of the GW) using it's private routing key (shall we use hostname-rnd to start with?)

Create a utility to register new functions

Create the workspace manager

public WorkspaceResourcesDescriptor prepare(Job job, FunctionDefinition functionDefinition) {
	
	String functionUniqueName = functionDefinition.getFunctionUniqueName();
	String jobId = job.getJobId();
	// create a job folder in some configured root folder, named by the job id and function name
	
	// copy in the FaaS libs to <ROOT>/<JOB>/faasLibs
	
	// copy in the function's libs to <ROOT>/<JOB>/lib
	
	// compile the source to <ROOT>/<JOB>/bin
	
	
	return null;
}

public void cleanup(WorkspaceResourcesDescriptor workspaceResourcesDescriptor) {
	// delete the folder recursively
}