org.springframework.data.redis.connection

Interface ReactiveGeoCommands

All Known Subinterfaces:

ReactiveClusterGeoCommands

public interface ReactiveGeoCommands

Redis Geo commands executed using reactive infrastructure.

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ReactiveGeoCommands.GeoAddCommand GEOADD command parameters.
static class	ReactiveGeoCommands.GeoDistCommand GEODIST command parameters.
static class	ReactiveGeoCommands.GeoHashCommand GEOHASH command parameters.
static class	ReactiveGeoCommands.GeoPosCommand GEOPOS command parameters.
static class	ReactiveGeoCommands.GeoRadiusByMemberCommand GEORADIUSBYMEMBER command parameters.
static class	ReactiveGeoCommands.GeoRadiusCommand GEORADIUS command parameters.

Method Summary

Modifier and Type	Method and Description
default reactor.core.publisher.Mono<Long>	geoAdd(ByteBuffer key, Collection<RedisGeoCommands.GeoLocation<ByteBuffer>> locations) Add RedisGeoCommands.GeoLocation to key.
default reactor.core.publisher.Mono<Long>	geoAdd(ByteBuffer key, Point point, ByteBuffer member) Add Point with given member to key.
default reactor.core.publisher.Mono<Long>	geoAdd(ByteBuffer key, RedisGeoCommands.GeoLocation<ByteBuffer> location) Add RedisGeoCommands.GeoLocation to key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,Long>>	geoAdd(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoAddCommand> commands) Add RedisGeoCommands.GeoLocations to key.
default reactor.core.publisher.Mono<Distance>	geoDist(ByteBuffer key, ByteBuffer from, ByteBuffer to) Get the Distance between from and to.
default reactor.core.publisher.Mono<Distance>	geoDist(ByteBuffer key, ByteBuffer from, ByteBuffer to, Metric metric) Get the Distance between from and to.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,Distance>>	geoDist(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoDistCommand> commands) Get the Distance between from and to.
default reactor.core.publisher.Mono<String>	geoHash(ByteBuffer key, ByteBuffer member) Get geohash representation of the position for the one member.
default reactor.core.publisher.Mono<List<String>>	geoHash(ByteBuffer key, Collection<ByteBuffer> members) Get geohash representation of the position for one or more members.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveGeoCommands.GeoHashCommand,String>>	geoHash(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoHashCommand> commands) Get geohash representation of the position for one or more members.
default reactor.core.publisher.Mono<Point>	geoPos(ByteBuffer key, ByteBuffer member) Get the Point representation of positions for the members.
default reactor.core.publisher.Mono<List<Point>>	geoPos(ByteBuffer key, Collection<ByteBuffer> members) Get the Point representation of positions for one or more members.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveGeoCommands.GeoPosCommand,Point>>	geoPos(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoPosCommand> commands) Get the Point representation of positions for one or more members.
default reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>	geoRadius(ByteBuffer key, Circle circle) Get the members within the boundaries of a given Circle.
default reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>	geoRadius(ByteBuffer key, Circle circle, RedisGeoCommands.GeoRadiusCommandArgs geoRadiusArgs) Get the members within the boundaries of a given Circle applying given parameters.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>>	geoRadius(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusCommand> commands) Get the members within the boundaries of a given Circle applying given parameters.
default reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>	geoRadiusByMember(ByteBuffer key, ByteBuffer member, Distance distance) Get the members within given Distance from member applying given parameters.
default reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>	geoRadiusByMember(ByteBuffer key, ByteBuffer member, Distance distance, RedisGeoCommands.GeoRadiusCommandArgs geoRadiusArgs) Get the members within given Distance from member applying given parameters.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusByMemberCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>>	geoRadiusByMember(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands) Get the members within given Distance from member applying given parameters.

Method Detail

geoAdd

default reactor.core.publisher.Mono<Long> geoAdd(ByteBuffer key,
                                                 Point point,
                                                 ByteBuffer member)

Add Point with given member to key.

Parameters:

key - must not be null.

point - must not be null.

member - must not be null.

Returns:

See Also:

Redis Documentation: GEOADD

geoAdd

default reactor.core.publisher.Mono<Long> geoAdd(ByteBuffer key,
                                                 RedisGeoCommands.GeoLocation<ByteBuffer> location)

Add RedisGeoCommands.GeoLocation to key.

Parameters:

key - must not be null.

location - must not be null.

Returns:

See Also:

Redis Documentation: GEOADD

geoAdd

default reactor.core.publisher.Mono<Long> geoAdd(ByteBuffer key,
                                                 Collection<RedisGeoCommands.GeoLocation<ByteBuffer>> locations)

Add RedisGeoCommands.GeoLocation to key.

Parameters:

key - must not be null.

locations - must not be null.

Returns:

See Also:

Redis Documentation: GEOADD

geoAdd

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,Long>> geoAdd(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoAddCommand> commands)

Add RedisGeoCommands.GeoLocations to key.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: GEOADD

geoDist

default reactor.core.publisher.Mono<Distance> geoDist(ByteBuffer key,
                                                      ByteBuffer from,
                                                      ByteBuffer to)

Get the Distance between from and to.

Parameters:

key - must not be null.

from - must not be null.

to - must not be null.

Returns:

See Also:

Redis Documentation: GEODIST

geoDist

default reactor.core.publisher.Mono<Distance> geoDist(ByteBuffer key,
                                                      ByteBuffer from,
                                                      ByteBuffer to,
                                                      Metric metric)

Get the Distance between from and to.

Parameters:

key - must not be null.

from - must not be null.

to - must not be null.

metric - must not be null.

Returns:

See Also:

Redis Documentation: GEODIST

geoDist

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,Distance>> geoDist(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoDistCommand> commands)

Get the Distance between from and to.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: GEODIST

geoHash

default reactor.core.publisher.Mono<String> geoHash(ByteBuffer key,
                                                    ByteBuffer member)

Get geohash representation of the position for the one member.

Parameters:

key - must not be null.

member - must not be null.

Returns:

See Also:

Redis Documentation: GEOHASH

geoHash

default reactor.core.publisher.Mono<List<String>> geoHash(ByteBuffer key,
                                                          Collection<ByteBuffer> members)

Get geohash representation of the position for one or more members.

Parameters:

key - must not be null.

members - must not be null.

Returns:

See Also:

Redis Documentation: GEOHASH

geoHash

reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveGeoCommands.GeoHashCommand,String>> geoHash(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoHashCommand> commands)

Get geohash representation of the position for one or more members.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: GEOHASH

geoPos

default reactor.core.publisher.Mono<Point> geoPos(ByteBuffer key,
                                                  ByteBuffer member)

Get the Point representation of positions for the members.

Parameters:

key - must not be null.

member - must not be null.

Returns:

See Also:

Redis Documentation: GEOPOS

geoPos

default reactor.core.publisher.Mono<List<Point>> geoPos(ByteBuffer key,
                                                        Collection<ByteBuffer> members)

Get the Point representation of positions for one or more members.

Parameters:

key - must not be null.

members - must not be null.

Returns:

See Also:

Redis Documentation: GEOPOS

geoPos

reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveGeoCommands.GeoPosCommand,Point>> geoPos(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoPosCommand> commands)

Get the Point representation of positions for one or more members.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: GEOPOS

geoRadius

default reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>> geoRadius(ByteBuffer key,
                                                                                                   Circle circle)

Get the members within the boundaries of a given Circle.

Parameters:

key - must not be null.

circle - must not be null.

Returns:

See Also:

Redis Documentation: GEORADIUS

geoRadius

default reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>> geoRadius(ByteBuffer key,
                                                                                                   Circle circle,
                                                                                                   RedisGeoCommands.GeoRadiusCommandArgs geoRadiusArgs)

Get the members within the boundaries of a given Circle applying given parameters.

Parameters:

key - must not be null.

circle - must not be null.

geoRadiusArgs - must not be null.

Returns:

See Also:

Redis Documentation: GEORADIUS

geoRadius

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> geoRadius(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusCommand> commands)

Get the members within the boundaries of a given Circle applying given parameters.

Parameters:

commands -

Returns:

See Also:

Redis Documentation: GEORADIUS

geoRadiusByMember

default reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>> geoRadiusByMember(ByteBuffer key,
                                                                                                           ByteBuffer member,
                                                                                                           Distance distance)

Get the members within given Distance from member applying given parameters.

Parameters:

key - must not be null.

member - must not be null.

Returns:

See Also:

Redis Documentation: GEORADIUSBYMEMBER

geoRadiusByMember

default reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>> geoRadiusByMember(ByteBuffer key,
                                                                                                           ByteBuffer member,
                                                                                                           Distance distance,
                                                                                                           RedisGeoCommands.GeoRadiusCommandArgs geoRadiusArgs)

Get the members within given Distance from member applying given parameters.

Parameters:

key - must not be null.

member - must not be null.

geoRadiusArgs - must not be null.

Returns:

See Also:

Redis Documentation: GEORADIUSBYMEMBER

geoRadiusByMember

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusByMemberCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> geoRadiusByMember(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands)

Get the members within given Distance from member applying given parameters.

Parameters:

commands - must not be null.

Returns:

See Also:

Redis Documentation: GEORADIUSBYMEMBER