Uses of Class
org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse

Packages that use ReactiveRedisConnection.CommandResponse

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.

Uses of ReactiveRedisConnection.CommandResponse in org.springframework.data.redis.connection

Subclasses of ReactiveRedisConnection.CommandResponse in org.springframework.data.redis.connection

Modifier and Type	Class	Description
static class	ReactiveListCommands.PopResponse	Result for ReactiveListCommands.PopCommand/ReactiveListCommands.BPopCommand.
static class	ReactiveRedisConnection.AbsentByteBufferResponse<I>	ReactiveRedisConnection.CommandResponse implementation for ByteBuffer responses for absent keys.
static class	ReactiveRedisConnection.BooleanResponse<I>	ReactiveRedisConnection.CommandResponse implementation for Boolean responses.
static class	ReactiveRedisConnection.ByteBufferResponse<I>	ReactiveRedisConnection.CommandResponse implementation for ByteBuffer responses.
static class	ReactiveRedisConnection.MultiValueResponse<I,O>	ReactiveRedisConnection.CommandResponse implementation for List responses.
static class	ReactiveRedisConnection.NumericResponse<I,O extends Number>	ReactiveRedisConnection.CommandResponse implementation for numeric responses.

Methods in org.springframework.data.redis.connection that return types with arguments of type ReactiveRedisConnection.CommandResponse

Modifier and Type	Method	Description
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.BZPopCommand,Flux<Tuple>>>	ReactiveZSetCommands.bZPop(Publisher<ReactiveZSetCommands.BZPopCommand> commands)	Remove and return elements from sorted set at keyCommand#getKey().
Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,Distance>>	ReactiveGeoCommands.geoDist(Publisher<ReactiveGeoCommands.GeoDistCommand> commands)	Get the Distance between from and to.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>>	ReactiveGeoCommands.geoRadius(Publisher<ReactiveGeoCommands.GeoRadiusCommand> commands)	Get the members within the boundaries of a given Circle applying given parameters.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusByMemberCommand,Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>>	ReactiveGeoCommands.geoRadiusByMember(Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands)	Get the members within given Distance from member applying given parameters.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoSearchCommand,Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>>	ReactiveGeoCommands.geoSearch(Publisher<ReactiveGeoCommands.GeoSearchCommand> commands)	Get the members within given GeoShape from GeoReference applying given parameters.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<Map.Entry<ByteBuffer,ByteBuffer>>>>	ReactiveHashCommands.hGetAll(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get entire hash stored at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<ByteBuffer>>>	ReactiveHashCommands.hKeys(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get key set (fields) of hash at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,Flux<ByteBuffer>>>	ReactiveHashCommands.hRandField(Publisher<ReactiveHashCommands.HRandFieldCommand> commands)	Get random fields of hash at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,Flux<Map.Entry<ByteBuffer,ByteBuffer>>>>	ReactiveHashCommands.hRandFieldWithValues(Publisher<ReactiveHashCommands.HRandFieldCommand> commands)	Get random fields along their values of hash at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<Map.Entry<ByteBuffer,ByteBuffer>>>>	ReactiveHashCommands.hScan(Publisher<ReactiveRedisConnection.KeyScanCommand> commands)	Use a Flux to iterate over entries in the hash at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<ByteBuffer>>>	ReactiveHashCommands.hVals(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get entry set (values) of hash at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,Flux<ByteBuffer>>>	ReactiveListCommands.lRange(Publisher<ReactiveRedisConnection.RangeCommand> commands)	Get elements in ReactiveRedisConnection.RangeCommand.getRange() from list at ReactiveRedisConnection.KeyCommand.getKey()
Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,Flux<ByteBuffer>>>	ReactiveListCommands.popList(Publisher<ReactiveListCommands.PopCommand> commands)	Removes and returns last element in list stored at ReactiveRedisConnection.KeyCommand.getKey()
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,Flux<ByteBufferRecord>>>	ReactiveStreamCommands.read(Publisher<ReactiveStreamCommands.ReadCommand> commands)	Read records from one or more StreamOffsets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,Flux<ByteBuffer>>>	ReactiveSetCommands.sDiff(Publisher<ReactiveSetCommands.SDiffCommand> commands)	Returns the diff of the members of all given sets at ReactiveSetCommands.SInterCommand.getKeys().
Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,Flux<ByteBuffer>>>	ReactiveSetCommands.sInter(Publisher<ReactiveSetCommands.SInterCommand> commands)	Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<ByteBuffer>>>	ReactiveSetCommands.sMembers(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get all elements of set at ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,Flux<ByteBuffer>>>	ReactiveSetCommands.sRandMember(Publisher<ReactiveSetCommands.SRandMembersCommand> commands)	Get ReactiveSetCommands.SRandMembersCommand.getCount() random elements from set at ReactiveRedisConnection.KeyCommand.getKey().
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<ByteBuffer>>>	ReactiveSetCommands.sScan(Publisher<ReactiveRedisConnection.KeyScanCommand> commands)	Use a Flux to iterate over members in the set at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,Flux<ByteBuffer>>>	ReactiveSetCommands.sUnion(Publisher<ReactiveSetCommands.SUnionCommand> commands)	Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,DataType>>	ReactiveKeyCommands.type(Publisher<ReactiveRedisConnection.KeyCommand> keys)	Determine the type stored at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>>	ReactiveStreamCommands.xAdd(Publisher<ReactiveStreamCommands.AddStreamRecord> commands)	Add stream record with given body to key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,Flux<ByteBufferRecord>>>	ReactiveStreamCommands.xClaim(Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,Flux<RecordId>>>	ReactiveStreamCommands.xClaimJustId(Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer without increasing the delivered count.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,Long>>	ReactiveStreamCommands.xDel(Publisher<ReactiveStreamCommands.DeleteCommand> commands)	Removes the specified entries from the stream.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,String>>	ReactiveStreamCommands.xGroup(Publisher<ReactiveStreamCommands.GroupCommand> commands)	Execute the given ReactiveStreamCommands.GroupCommand to create, destroy,... groups.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>>	ReactiveStreamCommands.xInfo(Publisher<ReactiveStreamCommands.XInfoCommand> commands)	Obtain general information about the stream stored at the specified key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,Flux<StreamInfo.XInfoConsumer>>>	ReactiveStreamCommands.xInfoConsumers(Publisher<ReactiveStreamCommands.XInfoCommand> commands)	Obtain information about every consumer in a specific consumer group for the stream stored at the specified key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,Flux<StreamInfo.XInfoGroup>>>	ReactiveStreamCommands.xInfoGroups(Publisher<ReactiveStreamCommands.XInfoCommand> commands)	Obtain general information about the stream stored at the specified key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessages>>	ReactiveStreamCommands.xPending(Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)	Obtain detailed information about pending messages applying given options.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessagesSummary>>	ReactiveStreamCommands.xPendingSummary(Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)	Obtain the PendingMessagesSummary for a given consumer group.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,Flux<ByteBufferRecord>>>	ReactiveStreamCommands.xRange(Publisher<ReactiveStreamCommands.RangeCommand> commands)	Read records from a stream within a specific Range applying a Limit.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,Flux<ByteBufferRecord>>>	ReactiveStreamCommands.xRevRange(Publisher<ReactiveStreamCommands.RangeCommand> commands)	Read records from a stream within a specific Range applying a Limit in reverse order.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,Flux<ByteBuffer>>>	ReactiveZSetCommands.zDiff(Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands)	Diff sorted sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,Flux<Tuple>>>	ReactiveZSetCommands.zDiffWithScores(Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands)	Diff sorted sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<ByteBuffer>>>	ReactiveZSetCommands.zInter(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<Tuple>>>	ReactiveZSetCommands.zInterWithScores(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZPopCommand,Flux<Tuple>>>	ReactiveZSetCommands.zPop(Publisher<ReactiveZSetCommands.ZPopCommand> commands)	Remove and return elements from sorted set at keyCommand#getKey().
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,Flux<ByteBuffer>>>	ReactiveZSetCommands.zRandMember(Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands)	Get random elements from sorted set at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,Flux<Tuple>>>	ReactiveZSetCommands.zRandMemberWithScore(Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands)	Get random elements from sorted set at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,Flux<Tuple>>>	ReactiveZSetCommands.zRange(Publisher<ReactiveZSetCommands.ZRangeCommand> commands)	Get set of Tuples in range from sorted set.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByLexCommand,Flux<ByteBuffer>>>	ReactiveZSetCommands.zRangeByLex(Publisher<ReactiveZSetCommands.ZRangeByLexCommand> commands)	Get all elements in Range from the sorted set at key in lexicographical ordering.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,Flux<Tuple>>>	ReactiveZSetCommands.zRangeByScore(Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands)	Get Tuples in range from sorted set.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeStoreCommand,Mono<Long>>>	ReactiveZSetCommands.zRangeStore(Publisher<ReactiveZSetCommands.ZRangeStoreCommand> commands)	Get set of Tuples in range from sorted set.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Flux<Tuple>>>	ReactiveZSetCommands.zScan(Publisher<ReactiveRedisConnection.KeyScanCommand> commands)	Use a Flux to iterate over members in the sorted set at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<ByteBuffer>>>	ReactiveZSetCommands.zUnion(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Union sorted sets by applying aggregateFunction and apply weights to individual sets.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,Flux<Tuple>>>	ReactiveZSetCommands.zUnionWithScores(Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Union sorted sets by applying aggregateFunction and apply weights to individual sets.