Uses of Interface
org.springframework.data.redis.connection.ReactiveRedisConnection
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Core package for integrating Redis with Spring concepts.
Lua script execution abstraction.
-
Uses of ReactiveRedisConnection in org.springframework.data.redis.connection
-
Uses of ReactiveRedisConnection in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionprotected ReactiveRedisConnection
ReactiveRedisTemplate.createRedisConnectionProxy
(ReactiveRedisConnection reactiveRedisConnection) protected ReactiveRedisConnection
ReactiveRedisTemplate.preProcessConnection
(ReactiveRedisConnection connection, boolean existingConnection) Processes the connection (before any settings are executed on it).Modifier and TypeMethodDescriptionprotected reactor.core.publisher.Mono<ReactiveRedisConnection>
ReactiveRedisTemplate.getConnection()
Creates aMono
which emits a newReactiveRedisConnection
.Modifier and TypeMethodDescriptionprotected ReactiveRedisConnection
ReactiveRedisTemplate.createRedisConnectionProxy
(ReactiveRedisConnection reactiveRedisConnection) org.reactivestreams.Publisher<T>
ReactiveRedisCallback.doInRedis
(ReactiveRedisConnection connection) Gets called byReactiveRedisTemplate.execute(ReactiveRedisCallback)
with an active Redis connection.protected <T> org.reactivestreams.Publisher<T>
ReactiveRedisTemplate.postProcessResult
(org.reactivestreams.Publisher<T> result, ReactiveRedisConnection connection, boolean existingConnection) Processes the result before returning thePublisher
.protected ReactiveRedisConnection
ReactiveRedisTemplate.preProcessConnection
(ReactiveRedisConnection connection, boolean existingConnection) Processes the connection (before any settings are executed on it). -
Uses of ReactiveRedisConnection in org.springframework.data.redis.core.script
Modifier and TypeMethodDescriptionprotected <T> reactor.core.publisher.Flux<T>
DefaultReactiveScriptExecutor.eval
(ReactiveRedisConnection connection, RedisScript<T> script, ReturnType returnType, int numKeys, ByteBuffer[] keysAndArgs, RedisElementReader<T> resultReader)