Uses of Class
org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
-
Uses of ReactiveRedisConnection.CommandResponse in org.springframework.data.redis.connection
Modifier and TypeClassDescriptionstatic class
static class
ReactiveRedisConnection.CommandResponse
implementation forByteBuffer
responses for absent keys.static class
ReactiveRedisConnection.CommandResponse
implementation forBoolean
responses.static class
ReactiveRedisConnection.CommandResponse
implementation forByteBuffer
responses.static class
ReactiveRedisConnection.CommandResponse
implementation forList
responses.static class
ReactiveRedisConnection.NumericResponse<I,
O extends Number> ReactiveRedisConnection.CommandResponse
implementation fornumeric
responses.Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.BZPopCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.bZPop
(org.reactivestreams.Publisher<ReactiveZSetCommands.BZPopCommand> commands) Remove and return elements from sorted set atkeyCommand#getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,
org.springframework.data.geo.Distance>> ReactiveGeoCommands.geoDist
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoDistCommand> commands) Get theDistance
between from and to.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,
reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> ReactiveGeoCommands.geoRadius
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusCommand> commands) Get the members within the boundaries of a givenCircle
applying given parameters.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusByMemberCommand,
reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> ReactiveGeoCommands.geoRadiusByMember
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands) Get the members within givenDistance
from member applying given parameters.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoSearchCommand,
reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> ReactiveGeoCommands.geoSearch
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchCommand> commands) Get the members within givenGeoShape
fromGeoReference
applying given parameters.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<Map.Entry<ByteBuffer, ByteBuffer>>>> ReactiveHashCommands.hGetAll
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get entire hash stored at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveHashCommands.hKeys
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get key set (fields) of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveHashCommands.hRandField
(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands) Get random fields of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,
reactor.core.publisher.Flux<Map.Entry<ByteBuffer, ByteBuffer>>>> ReactiveHashCommands.hRandFieldWithValues
(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands) Get random fields along their values of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<Map.Entry<ByteBuffer, ByteBuffer>>>> ReactiveHashCommands.hScan
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use aFlux
to iterate over entries in the hash atkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveHashCommands.hVals
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get entry set (values) of hash at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveListCommands.lRange
(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands) Get elements inReactiveRedisConnection.RangeCommand.getRange()
from list atReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveListCommands.popList
(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands) Removes and returns last element in list stored atReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,
reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.read
(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands) Read records from one or moreStreamOffset
s.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveSetCommands.sDiff
(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffCommand> commands) Returns the diff of the members of all given sets atReactiveSetCommands.SInterCommand.getKeys()
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveSetCommands.sInter
(org.reactivestreams.Publisher<ReactiveSetCommands.SInterCommand> commands) Returns the members intersecting all given sets atReactiveSetCommands.SInterCommand.getKeys()
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveSetCommands.sMembers
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get all elements of set atReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveSetCommands.sRandMember
(org.reactivestreams.Publisher<ReactiveSetCommands.SRandMembersCommand> commands) GetReactiveSetCommands.SRandMembersCommand.getCount()
random elements from set atReactiveRedisConnection.KeyCommand.getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveSetCommands.sScan
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use aFlux
to iterate over members in the set atkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveSetCommands.sUnion
(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionCommand> commands) Returns the members intersecting all given sets atReactiveSetCommands.SInterCommand.getKeys()
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
DataType>> ReactiveKeyCommands.type
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Determine the type stored at key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,
RecordId>> ReactiveStreamCommands.xAdd
(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands) Add stream record with given body to key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,
reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.xClaim
(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands) Change the ownership of a pending message to the given new consumer.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,
reactor.core.publisher.Flux<RecordId>>> ReactiveStreamCommands.xClaimJustId
(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands) Change the ownership of a pending message to the given new consumer without increasing the delivered count.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,
Long>> ReactiveStreamCommands.xDel
(org.reactivestreams.Publisher<ReactiveStreamCommands.DeleteCommand> commands) Removes the specified entries from the stream.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,
String>> ReactiveStreamCommands.xGroup
(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands) Execute the givenReactiveStreamCommands.GroupCommand
to create, destroy,... groups.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,
StreamInfo.XInfoStream>> ReactiveStreamCommands.xInfo
(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands) Obtain general information about the stream stored at the specified key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,
reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>>> ReactiveStreamCommands.xInfoConsumers
(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands) Obtain information about every consumer in a specific consumer group for the stream stored at the specified key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,
reactor.core.publisher.Flux<StreamInfo.XInfoGroup>>> ReactiveStreamCommands.xInfoGroups
(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands) Obtain general information about the stream stored at the specified key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,
PendingMessages>> ReactiveStreamCommands.xPending
(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,
PendingMessagesSummary>> ReactiveStreamCommands.xPendingSummary
(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands) Obtain thePendingMessagesSummary
for a given consumer group.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,
reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.xRange
(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands) Read records from a stream within a specificRange
applying aLimit
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,
reactor.core.publisher.Flux<ByteBufferRecord>>> ReactiveStreamCommands.xRevRange
(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands) Read records from a stream within a specificRange
applying aLimit
in reverse order.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveZSetCommands.zDiff
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands) Diff sorted sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zDiffWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands) Diff sorted sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveZSetCommands.zInter
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zInterWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZPopCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zPop
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZPopCommand> commands) Remove and return elements from sorted set atkeyCommand#getKey()
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveZSetCommands.zRandMember
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands) Get random elements from sorted set atkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zRandMemberWithScore
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands) Get random elements from sorted set atkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zRange
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeCommand> commands) Get set ofTuple
s in range from sorted set.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByLexCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveZSetCommands.zRangeByLex
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByLexCommand> commands) Get all elements inRange
from the sorted set at key in lexicographical ordering.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zRangeByScore
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands) GetTuple
s in range from sorted set.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeStoreCommand,
reactor.core.publisher.Mono<Long>>> ReactiveZSetCommands.zRangeStore
(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeStoreCommand> commands) Get set ofTuple
s in range from sorted set.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zScan
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Use aFlux
to iterate over members in the sorted set atkey
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveZSetCommands.zUnion
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Union sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zUnionWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Union sorted sets by applying aggregateFunction and apply weights to individual sets.