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 and 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.
reactor.core.publisher.Flux<Boolean>	scriptExists(List<String> scriptShas) Check if given scriptShas exist in script cache.
default reactor.core.publisher.Mono<Boolean>	scriptExists(String scriptSha) Check if given scriptSha 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.

Method Detail

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