Class LuaTaskEngine

java.lang.Object

org.infinispan.server.resp.scripting.LuaTaskEngine

All Implemented Interfaces:

org.infinispan.tasks.spi.TaskEngine

public class LuaTaskEngine
extends Object
implements org.infinispan.tasks.spi.TaskEngine

An Infinispan TaskEngine built specifically for executing lua scripts in the context of the resp connector. It is therefore not a generic task engine or a scripting engine that can be used from Hot Rod or REST.

Constructor Summary

Constructors

Constructor	Description
LuaTaskEngine(ScriptingManager scriptingManager)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	eval(Resp3Handler handler, io.netty.channel.ChannelHandlerContext ctx, String code, String[] keys, String[] args, long flags)
CompletionStage<Void>	evalSha(Resp3Handler handler, io.netty.channel.ChannelHandlerContext ctx, String sha, String[] keys, String[] args, long flags)
String	getName()
List<Task>	getTasks()
boolean	handles(String taskName)
<T> CompletionStage<T>	runTask(String taskName, TaskContext context, BlockingManager blockingManager)
List<Integer>	scriptExists(List<String> shas)
void	scriptFlush()
LuaCode	scriptLoad(String script, boolean persistent)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Details

LuaTaskEngine

public LuaTaskEngine(ScriptingManager scriptingManager)

Method Details

shutdown

public void shutdown()

eval

public CompletionStage<Void> eval(Resp3Handler handler,
 io.netty.channel.ChannelHandlerContext ctx,
 String code,
 String[] keys,
 String[] args,
 long flags)

evalSha

public CompletionStage<Void> evalSha(Resp3Handler handler,
 io.netty.channel.ChannelHandlerContext ctx,
 String sha,
 String[] keys,
 String[] args,
 long flags)

scriptLoad

public LuaCode scriptLoad(String script,
 boolean persistent)

scriptExists

public List<Integer> scriptExists(List<String> shas)

scriptFlush

public void scriptFlush()

getName

public String getName()

Specified by:

getName in interface org.infinispan.tasks.spi.TaskEngine

getTasks

public List<Task> getTasks()

Specified by:

getTasks in interface org.infinispan.tasks.spi.TaskEngine

runTask

public <T> CompletionStage<T> runTask(String taskName,
 TaskContext context,
 BlockingManager blockingManager)

Specified by:

runTask in interface org.infinispan.tasks.spi.TaskEngine

handles

public boolean handles(String taskName)

Specified by:

handles in interface org.infinispan.tasks.spi.TaskEngine