Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
Modifier and Type | Class and Description |
---|---|
static class |
ReactiveListCommands.PopResponse
|
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. |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,Distance>> |
ReactiveGeoCommands.geoDist(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoDistCommand> commands)
Get the
Distance between from and to. |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> |
ReactiveGeoCommands.geoRadius(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusCommand> commands)
Get the members within the boundaries of a given
Circle applying given parameters. |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusByMemberCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> |
ReactiveGeoCommands.geoRadiusByMember(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands)
Get the members within given
Distance from member 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<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>> |
ReactiveHashCommands.hScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)
Use a
Flux to iterate over entries in the hash at key . |
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 in
ReactiveRedisConnection.RangeCommand.getRange() from list at ReactiveRedisConnection.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 more
StreamOffset 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 at
ReactiveSetCommands.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 at
ReactiveSetCommands.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 at
ReactiveRedisConnection.KeyCommand.getKey() . |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,reactor.core.publisher.Flux<ByteBuffer>>> |
ReactiveSetCommands.sRandMember(org.reactivestreams.Publisher<ReactiveSetCommands.SRandMembersCommand> commands)
Get
ReactiveSetCommands.SRandMembersCommand.getCount() random elements from set at ReactiveRedisConnection.KeyCommand.getKey() . |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>> |
ReactiveSetCommands.sScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)
Use a
Flux to iterate over members in the set at key . |
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 at
ReactiveSetCommands.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 given
ReactiveStreamCommands.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 the
PendingMessagesSummary 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 specific
Range applying a RedisZSetCommands.Limit . |
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 specific
Range applying a RedisZSetCommands.Limit in reverse order. |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>> |
ReactiveZSetCommands.zRange(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeCommand> commands)
Get set of
RedisZSetCommands.Tuple 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 in
Range from the sorted set at key in lexicographical ordering. |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>> |
ReactiveZSetCommands.zRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands)
Get
RedisZSetCommands.Tuple s in range from sorted set. |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<RedisZSetCommands.Tuple>>> |
ReactiveZSetCommands.zScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)
Use a
Flux to iterate over members in the sorted set at key . |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.