Package org.springframework.data.redis.connection

Interface ReactiveScriptingCommands

All Known Subinterfaces:

ReactiveClusterScriptingCommands

public interface ReactiveScriptingCommands

Redis Scripting commands executed using reactive infrastructure.

Since:

2.0

Author:

Mark Paluch, Christoph Strobl

Method Summary

Modifier and Type	Method	Description
<T> reactor.core.publisher.Flux<T>	eval(ByteBuffer script, ReturnType returnType, int numKeys, ByteBuffer... keysAndArgs)	Evaluate given script.
<T> reactor.core.publisher.Flux<T>	evalSha(String scriptSha, ReturnType returnType, int numKeys, ByteBuffer... keysAndArgs)	Evaluate given scriptSha.
default reactor.core.publisher.Mono<Boolean>	scriptExists(String scriptSha)	Check if given scriptSha exist in script cache.
reactor.core.publisher.Flux<Boolean>	scriptExists(List<String> scriptShas)	Check if given scriptShas exist in script cache.
reactor.core.publisher.Mono<String>	scriptFlush()	Flush lua script cache.
reactor.core.publisher.Mono<String>	scriptKill()	Kill current lua script execution.
reactor.core.publisher.Mono<String>	scriptLoad(ByteBuffer script)	Load lua script into scripts cache, without executing it. Execute the script by calling evalSha(String, ReturnType, int, ByteBuffer...).

Method Details

scriptFlush

reactor.core.publisher.Mono<String> scriptFlush()

Flush lua script cache.

See Also:

• Redis Documentation: SCRIPT FLUSH

scriptKill

reactor.core.publisher.Mono<String> scriptKill()

Kill current lua script execution.

See Also:

• Redis Documentation: SCRIPT KILL

scriptLoad

reactor.core.publisher.Mono<String> scriptLoad(ByteBuffer script)

Load lua script into scripts cache, without executing it.
Execute the script by calling evalSha(String, ReturnType, int, ByteBuffer...).

Parameters:

script - must not be null.

Returns:

never null.

See Also:

• Redis Documentation: SCRIPT LOAD

scriptExists

default reactor.core.publisher.Mono<Boolean> scriptExists(String scriptSha)

Check if given scriptSha exist in script cache.

Parameters:

scriptSha - The sha1 of the script is present in script cache. Must not be null.

Returns:

a Mono indicating if script is present.

scriptExists

reactor.core.publisher.Flux<Boolean> scriptExists(List<String> scriptShas)

Check if given scriptShas exist in script cache.

Parameters:

scriptShas - must not be null.

Returns:

Flux emitting one entry per scriptSha in given List.

See Also:

• Redis Documentation: SCRIPT EXISTS

eval

<T> reactor.core.publisher.Flux<T> eval(ByteBuffer script,
 ReturnType returnType,
 int numKeys,
 ByteBuffer... keysAndArgs)

Evaluate given script.

Parameters:

script - must not be null.

returnType - must not be null. Using ReturnType.MULTI emits a List as-is instead of emitting the individual elements from the array response.

numKeys -

keysAndArgs - must not be null.

Returns:

never null.

See Also:

• Redis Documentation: EVAL

evalSha

<T> reactor.core.publisher.Flux<T> evalSha(String scriptSha,
 ReturnType returnType,
 int numKeys,
 ByteBuffer... keysAndArgs)

Evaluate given scriptSha.

Parameters:

scriptSha - must not be null.

returnType - must not be null. Using ReturnType.MULTI emits a List as-is instead of emitting the individual elements from the array response.

numKeys -

keysAndArgs - must not be null.

Returns:

never null.

See Also:

• Redis Documentation: EVALSHA