Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

Interface RedisScriptingReactiveOperations<A,B>

Type Parameters:

A - key type

B - value type

All Known Subinterfaces:

RedisClient<A,B>, RedisOperations<A,B>, RedisTransactionalClient<A,B>, RedisTransactionalOperations<A,B>

All Known Implementing Classes:

io.inverno.mod.redis.lettuce.internal.AbstractRedisClient, PoolRedisClient, PoolRedisClusterClient

public interface RedisScriptingReactiveOperations<A,B>

Redis Scripting reactive commands.

Since:

1.4

Author:

Jeremy Kuhn

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	RedisScriptingReactiveOperations.ScriptFlushMode
static enum	RedisScriptingReactiveOperations.ScriptOutput

Method Summary

Modifier and Type	Method	Description
String	digest(byte[] script)
String	digest(String script)
<T> Flux<T>	eval(byte[] script, RedisScriptingReactiveOperations.ScriptOutput output)	EVAL script 0
<T> Flux<T>	eval(byte[] script, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys)	EVAL script numkeys [key [key ...]]
<T> Flux<T>	eval(byte[] script, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys, Consumer<Values<B>> args)	EVAL script numkeys [key [key ...]]
<T> Flux<T>	eval(String script, RedisScriptingReactiveOperations.ScriptOutput output)	EVAL script 0
<T> Flux<T>	eval(String script, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys)	EVAL script numkeys [key [key ...]]
<T> Flux<T>	eval(String script, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys, Consumer<Values<B>> args)	EVAL script numkeys [key [key ...]]
<T> Flux<T>	eval_ro(byte[] script, RedisScriptingReactiveOperations.ScriptOutput output)	EVAL_RO script 0
<T> Flux<T>	eval_ro(byte[] script, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys)	EVAL_RO script numkeys [key [key ...]]
<T> Flux<T>	eval_ro(byte[] script, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys, Consumer<Values<B>> args)	EVAL_RO script numkeys [key [key ...]]
<T> Flux<T>	eval_ro(String script, RedisScriptingReactiveOperations.ScriptOutput output)	EVAL_RO script 0
<T> Flux<T>	eval_ro(String script, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys)	EVAL_RO script numkeys [key [key ...]]
<T> Flux<T>	eval_ro(String script, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys, Consumer<Values<B>> args)	EVAL_RO script numkeys [key [key ...]]
<T> Flux<T>	evalsha(String digest, RedisScriptingReactiveOperations.ScriptOutput output)	EVALSHA script 0
<T> Flux<T>	evalsha(String digest, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys)	EVALSHA script numkeys [key [key ...]]
<T> Flux<T>	evalsha(String digest, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys, Consumer<Values<B>> args)	EVALSHA script numkeys [key [key ...]]
<T> Flux<T>	evalsha_ro(String digest, RedisScriptingReactiveOperations.ScriptOutput output)	EVALSHA_RO script 0
<T> Flux<T>	evalsha_ro(String digest, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys)	EVALSHA_RO script numkeys [key [key ...]]
<T> Flux<T>	evalsha_ro(String digest, RedisScriptingReactiveOperations.ScriptOutput output, Consumer<Keys<A>> keys, Consumer<Values<B>> args)	EVALSHA_RO script numkeys [key [key ...]]
Flux<Boolean>	scriptExists(String... digests)	SCRIPT EXISTS sha1 [sha1 ...]
Mono<String>	scriptFlush()	SCRIPT FLUSH
Mono<String>	scriptFlush(RedisScriptingReactiveOperations.ScriptFlushMode flushMode)	SCRIPT FLUSH [ASYNC|SYNC]
Mono<String>	scriptKill()	SCRIPT KILL
Mono<String>	scriptLoad(byte[] script)	SCRIPT LOAD script
Mono<String>	scriptLoad(String script)	SCRIPT LOAD script

Method Details

digest

String digest(byte[] script)

Parameters:

script -

Returns:

digest

String digest(String script)

Parameters:

script -

Returns:

eval

<T> Flux<T> eval(String script,
 RedisScriptingReactiveOperations.ScriptOutput output)

EVAL script 0

Type Parameters:

T -

Parameters:

script -

output -

Returns:

eval

<T> Flux<T> eval(byte[] script,
 RedisScriptingReactiveOperations.ScriptOutput output)

EVAL script 0

Type Parameters:

T -

Parameters:

script -

output -

Returns:

eval

<T> Flux<T> eval(String script,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys)

EVAL script numkeys [key [key ...]]

Type Parameters:

T -

Parameters:

script -

output -

keys -

Returns:

eval

<T> Flux<T> eval(byte[] script,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys)

EVAL script numkeys [key [key ...]]

Type Parameters:

T -

Parameters:

script -

output -

keys -

Returns:

eval

<T> Flux<T> eval(String script,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys,
 Consumer<Values<B>> args)

EVAL script numkeys [key [key ...]] [arg [arg ...]]

Type Parameters:

T -

Parameters:

script -

output -

keys -

args -

Returns:

eval

<T> Flux<T> eval(byte[] script,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys,
 Consumer<Values<B>> args)

EVAL script numkeys [key [key ...]] [arg [arg ...]]

Type Parameters:

T -

Parameters:

script -

output -

keys -

args -

Returns:

eval_ro

<T> Flux<T> eval_ro(String script,
 RedisScriptingReactiveOperations.ScriptOutput output)

EVAL_RO script 0

Type Parameters:

T -

Parameters:

script -

output -

Returns:

eval_ro

<T> Flux<T> eval_ro(byte[] script,
 RedisScriptingReactiveOperations.ScriptOutput output)

EVAL_RO script 0

Type Parameters:

T -

Parameters:

script -

output -

Returns:

eval_ro

<T> Flux<T> eval_ro(String script,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys)

EVAL_RO script numkeys [key [key ...]]

Type Parameters:

T -

Parameters:

script -

output -

keys -

Returns:

eval_ro

<T> Flux<T> eval_ro(byte[] script,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys)

EVAL_RO script numkeys [key [key ...]]

Type Parameters:

T -

Parameters:

script -

output -

keys -

Returns:

eval_ro

<T> Flux<T> eval_ro(String script,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys,
 Consumer<Values<B>> args)

EVAL_RO script numkeys [key [key ...]] [arg [arg ...]]

Type Parameters:

T -

Parameters:

script -

output -

keys -

args -

Returns:

eval_ro

<T> Flux<T> eval_ro(byte[] script,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys,
 Consumer<Values<B>> args)

EVAL_RO script numkeys [key [key ...]] [arg [arg ...]]

Type Parameters:

T -

Parameters:

script -

output -

keys -

args -

Returns:

evalsha

<T> Flux<T> evalsha(String digest,
 RedisScriptingReactiveOperations.ScriptOutput output)

EVALSHA script 0

Type Parameters:

T -

Parameters:

digest -

output -

Returns:

evalsha

<T> Flux<T> evalsha(String digest,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys)

EVALSHA script numkeys [key [key ...]]

Type Parameters:

T -

Parameters:

digest -

output -

keys -

Returns:

evalsha

<T> Flux<T> evalsha(String digest,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys,
 Consumer<Values<B>> args)

EVALSHA script numkeys [key [key ...]] [arg [arg ...]]

Type Parameters:

T -

Parameters:

digest -

output -

keys -

args -

Returns:

evalsha_ro

<T> Flux<T> evalsha_ro(String digest,
 RedisScriptingReactiveOperations.ScriptOutput output)

EVALSHA_RO script 0

Type Parameters:

T -

Parameters:

digest -

output -

Returns:

evalsha_ro

<T> Flux<T> evalsha_ro(String digest,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys)

EVALSHA_RO script numkeys [key [key ...]]

Type Parameters:

T -

Parameters:

digest -

output -

keys -

Returns:

evalsha_ro

<T> Flux<T> evalsha_ro(String digest,
 RedisScriptingReactiveOperations.ScriptOutput output,
 Consumer<Keys<A>> keys,
 Consumer<Values<B>> args)

EVALSHA_RO script numkeys [key [key ...]] [arg [arg ...]]

Type Parameters:

T -

Parameters:

digest -

output -

keys -

args -

Returns:

scriptExists

Flux<Boolean> scriptExists(String... digests)

SCRIPT EXISTS sha1 [sha1 ...]

Parameters:

digests -

Returns:

scriptFlush

Mono<String> scriptFlush()

SCRIPT FLUSH

Returns:

scriptFlush

Mono<String> scriptFlush(RedisScriptingReactiveOperations.ScriptFlushMode flushMode)

SCRIPT FLUSH [ASYNC|SYNC]

Parameters:

flushMode -

Returns:

scriptKill

Mono<String> scriptKill()

SCRIPT KILL

Returns:

scriptLoad

Mono<String> scriptLoad(String script)

SCRIPT LOAD script

Parameters:

script -

Returns:

scriptLoad

Mono<String> scriptLoad(byte[] script)

SCRIPT LOAD script

Parameters:

script -

Returns: