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
Modifier and TypeInterfaceDescriptionstatic class
GEOADD
command parameters.static class
GEODIST
command parameters.static class
GEOHASH
command parameters.static class
GEOPOS
command parameters.static class
GEORADIUSBYMEMBER
command parameters.static class
GEORADIUS
command parameters.static class
GEOSEARCH
command parameters.static class
GEOSEARCHSTORE
command parameters. -
Method Summary
Modifier and TypeMethodDescriptiondefault reactor.core.publisher.Mono<Long>
geoAdd
(ByteBuffer key, Collection<RedisGeoCommands.GeoLocation<ByteBuffer>> locations) AddRedisGeoCommands.GeoLocation
to key.default reactor.core.publisher.Mono<Long>
geoAdd
(ByteBuffer key, org.springframework.data.geo.Point point, ByteBuffer member) AddPoint
with given member to key.default reactor.core.publisher.Mono<Long>
geoAdd
(ByteBuffer key, RedisGeoCommands.GeoLocation<ByteBuffer> location) AddRedisGeoCommands.GeoLocation
to key.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,
Long>> geoAdd
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoAddCommand> commands) AddRedisGeoCommands.GeoLocation
s to key.default reactor.core.publisher.Mono<org.springframework.data.geo.Distance>
geoDist
(ByteBuffer key, ByteBuffer from, ByteBuffer to) Get theDistance
between from and to.default reactor.core.publisher.Mono<org.springframework.data.geo.Distance>
geoDist
(ByteBuffer key, ByteBuffer from, ByteBuffer to, org.springframework.data.geo.Metric metric) Get theDistance
between from and to.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,
org.springframework.data.geo.Distance>> geoDist
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoDistCommand> commands) Get theDistance
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.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<org.springframework.data.geo.Point>
geoPos
(ByteBuffer key, ByteBuffer member) Get thePoint
representation of positions for the members.default reactor.core.publisher.Mono<List<org.springframework.data.geo.Point>>
geoPos
(ByteBuffer key, Collection<ByteBuffer> members) Get thePoint
representation of positions for one or more members.reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveGeoCommands.GeoPosCommand,
org.springframework.data.geo.Point>> geoPos
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoPosCommand> commands) Get thePoint
representation of positions for one or more members.default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>
geoRadius
(ByteBuffer key, org.springframework.data.geo.Circle circle) Get the members within the boundaries of a givenCircle
.default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>
geoRadius
(ByteBuffer key, org.springframework.data.geo.Circle circle, RedisGeoCommands.GeoRadiusCommandArgs geoRadiusArgs) Get the members within the boundaries of a givenCircle
applying given parameters.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,
reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> geoRadius
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusCommand> commands) Get the members within the boundaries of a givenCircle
applying given parameters.default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>
geoRadiusByMember
(ByteBuffer key, ByteBuffer member, org.springframework.data.geo.Distance distance) Get the members within givenDistance
from member applying given parameters.default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>
geoRadiusByMember
(ByteBuffer key, ByteBuffer member, org.springframework.data.geo.Distance distance, RedisGeoCommands.GeoRadiusCommandArgs geoRadiusArgs) Get the members within givenDistance
from member applying given parameters.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusByMemberCommand,
reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> geoRadiusByMember
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands) Get the members within givenDistance
from member applying given parameters.default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>
geoSearch
(ByteBuffer key, GeoReference<ByteBuffer> reference, GeoShape shape, RedisGeoCommands.GeoSearchCommandArgs args) Return the members of a geo set which are within the borders of the area specified by a givenshape
.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoSearchCommand,
reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> geoSearch
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchCommand> commands) Get the members within givenGeoShape
fromGeoReference
applying given parameters.default reactor.core.publisher.Mono<Long>
geoSearchStore
(ByteBuffer destKey, ByteBuffer key, GeoReference<ByteBuffer> reference, GeoShape shape, RedisGeoCommands.GeoSearchStoreCommandArgs args) Query the members of a geo set which are within the borders of the area specified by a givenshape
and store the result atdestKey
.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoSearchStoreCommand,
Long>> geoSearchStore
(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchStoreCommand> commands) Store the members within givenGeoShape
fromGeoReference
applying given parameters in a new geo set.
-
Method Details
-
geoAdd
default reactor.core.publisher.Mono<Long> geoAdd(ByteBuffer key, org.springframework.data.geo.Point point, ByteBuffer member) AddPoint
with given member to key.- Parameters:
key
- must not be null.point
- must not be null.member
- must not be null.- Returns:
- See Also:
-
geoAdd
default reactor.core.publisher.Mono<Long> geoAdd(ByteBuffer key, RedisGeoCommands.GeoLocation<ByteBuffer> location) AddRedisGeoCommands.GeoLocation
to key.- Parameters:
key
- must not be null.location
- must not be null.- Returns:
- See Also:
-
geoAdd
default reactor.core.publisher.Mono<Long> geoAdd(ByteBuffer key, Collection<RedisGeoCommands.GeoLocation<ByteBuffer>> locations) AddRedisGeoCommands.GeoLocation
to key.- Parameters:
key
- must not be null.locations
- must not be null.- Returns:
- See Also:
-
geoAdd
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,Long>> geoAdd(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoAddCommand> commands) AddRedisGeoCommands.GeoLocation
s to key.- Parameters:
commands
- must not be null.- Returns:
- See Also:
-
geoDist
default reactor.core.publisher.Mono<org.springframework.data.geo.Distance> geoDist(ByteBuffer key, ByteBuffer from, ByteBuffer to) Get theDistance
between from and to.- Parameters:
key
- must not be null.from
- must not be null.to
- must not be null.- Returns:
- See Also:
-
geoDist
default reactor.core.publisher.Mono<org.springframework.data.geo.Distance> geoDist(ByteBuffer key, ByteBuffer from, ByteBuffer to, org.springframework.data.geo.Metric metric) Get theDistance
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:
-
geoDist
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,org.springframework.data.geo.Distance>> geoDist(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoDistCommand> commands) Get theDistance
between from and to.- Parameters:
commands
- must not be null.- Returns:
- See Also:
-
geoHash
Get geohash representation of the position for the one member.- Parameters:
key
- must not be null.member
- must not be null.- Returns:
- See Also:
-
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:
-
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:
-
geoPos
default reactor.core.publisher.Mono<org.springframework.data.geo.Point> geoPos(ByteBuffer key, ByteBuffer member) Get thePoint
representation of positions for the members.- Parameters:
key
- must not be null.member
- must not be null.- Returns:
- See Also:
-
geoPos
default reactor.core.publisher.Mono<List<org.springframework.data.geo.Point>> geoPos(ByteBuffer key, Collection<ByteBuffer> members) Get thePoint
representation of positions for one or more members.- Parameters:
key
- must not be null.members
- must not be null.- Returns:
- See Also:
-
geoPos
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveGeoCommands.GeoPosCommand,org.springframework.data.geo.Point>> geoPos(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoPosCommand> commands) Get thePoint
representation of positions for one or more members.- Parameters:
commands
- must not be null.- Returns:
- See Also:
-
geoRadius
default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>> geoRadius(ByteBuffer key, org.springframework.data.geo.Circle circle) Get the members within the boundaries of a givenCircle
.- Parameters:
key
- must not be null.circle
- must not be null.- Returns:
- See Also:
-
geoRadius
default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>> geoRadius(ByteBuffer key, org.springframework.data.geo.Circle circle, RedisGeoCommands.GeoRadiusCommandArgs geoRadiusArgs) Get the members within the boundaries of a givenCircle
applying given parameters.- Parameters:
key
- must not be null.circle
- must not be null.geoRadiusArgs
- must not be null.- Returns:
- See Also:
-
geoRadius
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> geoRadius(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusCommand> commands) Get the members within the boundaries of a givenCircle
applying given parameters.- Parameters:
commands
-- Returns:
- See Also:
-
geoRadiusByMember
default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>> geoRadiusByMember(ByteBuffer key, ByteBuffer member, org.springframework.data.geo.Distance distance) Get the members within givenDistance
from member applying given parameters.- Parameters:
key
- must not be null.member
- must not be null.- Returns:
- See Also:
-
geoRadiusByMember
default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>> geoRadiusByMember(ByteBuffer key, ByteBuffer member, org.springframework.data.geo.Distance distance, RedisGeoCommands.GeoRadiusCommandArgs geoRadiusArgs) Get the members within givenDistance
from member applying given parameters.- Parameters:
key
- must not be null.member
- must not be null.geoRadiusArgs
- must not be null.- Returns:
- See Also:
-
geoRadiusByMember
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusByMemberCommand,reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> geoRadiusByMember(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands) Get the members within givenDistance
from member applying given parameters.- Parameters:
commands
- must not be null.- Returns:
- See Also:
-
geoSearch
default reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>> geoSearch(ByteBuffer key, GeoReference<ByteBuffer> reference, GeoShape shape, RedisGeoCommands.GeoSearchCommandArgs args) Return the members of a geo set which are within the borders of the area specified by a givenshape
. The query's center point is provided byGeoReference
.- Parameters:
key
- must not be null.reference
- must not be null.shape
- must not be null.args
- must not be null.- Returns:
- Since:
- 2.6
- See Also:
-
geoSearch
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoSearchCommand,reactor.core.publisher.Flux<org.springframework.data.geo.GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>> geoSearch(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchCommand> commands) Get the members within givenGeoShape
fromGeoReference
applying given parameters.- Parameters:
commands
- must not be null.- Returns:
- Since:
- 2.6
- See Also:
-
geoSearchStore
default reactor.core.publisher.Mono<Long> geoSearchStore(ByteBuffer destKey, ByteBuffer key, GeoReference<ByteBuffer> reference, GeoShape shape, RedisGeoCommands.GeoSearchStoreCommandArgs args) Query the members of a geo set which are within the borders of the area specified by a givenshape
and store the result atdestKey
. The query's center point is provided byGeoReference
.- Parameters:
key
- must not be null.reference
- must not be null.shape
- must not be null.args
- must not be null.- Returns:
- Since:
- 2.6
- See Also:
-
geoSearchStore
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoSearchStoreCommand,Long>> geoSearchStore(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchStoreCommand> commands) Store the members within givenGeoShape
fromGeoReference
applying given parameters in a new geo set.- Parameters:
commands
- must not be null.- Returns:
- Since:
- 2.6
- See Also:
-