org.springframework.data.redis.connection.lettuce

Class LettuceReactiveGeoCommands

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveGeoCommands

All Implemented Interfaces:

ReactiveGeoCommands

Direct Known Subclasses:

LettuceReactiveClusterGeoCommands

public class LettuceReactiveGeoCommands
extends Object
implements ReactiveGeoCommands

Since:

2.0

Author:

Christoph Strobl

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.ReactiveGeoCommands

ReactiveGeoCommands.GeoAddCommand, ReactiveGeoCommands.GeoDistCommand, ReactiveGeoCommands.GeoHashCommand, ReactiveGeoCommands.GeoPosCommand, ReactiveGeoCommands.GeoRadiusByMemberCommand, ReactiveGeoCommands.GeoRadiusCommand

Constructor Summary

Constructors

Constructor and Description
LettuceReactiveGeoCommands(LettuceReactiveRedisConnection connection) Create new LettuceReactiveGeoCommands.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,Long>>	geoAdd(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoAddCommand> commands) Add RedisGeoCommands.GeoLocations to key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,Distance>>	geoDist(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoDistCommand> commands) Get the Distance between from and to.
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.
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.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,GeoResults<RedisGeoCommands.GeoLocation<ByteBuffer>>>>	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,GeoResults<RedisGeoCommands.GeoLocation<ByteBuffer>>>>	geoRadiusByMember(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands) Get the members within given Distance from member applying given parameters.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.data.redis.connection.ReactiveGeoCommands

geoAdd, geoAdd, geoAdd, geoDist, geoDist, geoHash, geoHash, geoPos, geoPos, geoRadius, geoRadius, geoRadiusByMember, geoRadiusByMember

Constructor Detail

LettuceReactiveGeoCommands

public LettuceReactiveGeoCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveGeoCommands.

Parameters:

connection - must not be null.

Method Detail

geoAdd

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

Description copied from interface: ReactiveGeoCommands

Add RedisGeoCommands.GeoLocations to key.

Specified by:

geoAdd in interface ReactiveGeoCommands

Parameters:

commands - must not be null.

Returns:

geoDist

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

Description copied from interface: ReactiveGeoCommands

Get the Distance between from and to.

Specified by:

geoDist in interface ReactiveGeoCommands

Parameters:

commands - must not be null.

Returns:

geoHash

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

Description copied from interface: ReactiveGeoCommands

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

Specified by:

geoHash in interface ReactiveGeoCommands

Parameters:

commands - must not be null.

Returns:

geoPos

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

Description copied from interface: ReactiveGeoCommands

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

Specified by:

geoPos in interface ReactiveGeoCommands

Parameters:

commands - must not be null.

Returns:

geoRadius

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

Description copied from interface: ReactiveGeoCommands

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

Specified by:

geoRadius in interface ReactiveGeoCommands

Returns:

geoRadiusByMember

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

Description copied from interface: ReactiveGeoCommands

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

Specified by:

geoRadiusByMember in interface ReactiveGeoCommands

Parameters:

commands - must not be null.

Returns: