org.springframework.data.redis.connection.lettuce

Class LettuceReactiveHashCommands

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveHashCommands

All Implemented Interfaces:

ReactiveHashCommands

Direct Known Subclasses:

LettuceReactiveClusterHashCommands

public class LettuceReactiveHashCommands
extends Object
implements ReactiveHashCommands

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

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

ReactiveHashCommands.HDelCommand, ReactiveHashCommands.HExistsCommand, ReactiveHashCommands.HGetCommand, ReactiveHashCommands.HSetCommand

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HDelCommand,Long>>	hDel(org.reactivestreams.Publisher<ReactiveHashCommands.HDelCommand> commands) Delete given hash fields.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HExistsCommand>>	hExists(org.reactivestreams.Publisher<ReactiveHashCommands.HExistsCommand> commands) Determine if given hash field exists.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Map<ByteBuffer,ByteBuffer>>>	hGetAll(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get entire hash stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveRedisConnection.KeyCommand,ByteBuffer>>	hKeys(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get key set (fields) of hash at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	hLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of hash at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveHashCommands.HGetCommand,ByteBuffer>>	hMGet(org.reactivestreams.Publisher<ReactiveHashCommands.HGetCommand> commands) Get values for given fields from hash at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HSetCommand>>	hSet(org.reactivestreams.Publisher<ReactiveHashCommands.HSetCommand> commands) Set the value of a hash field.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveRedisConnection.KeyCommand,ByteBuffer>>	hVals(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get entry set (values) of hash at key.

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.ReactiveHashCommands

hDel, hDel, hExists, hGet, hGetAll, hKeys, hLen, hMGet, hMSet, hSet, hSetNX, hVals

Constructor Detail

LettuceReactiveHashCommands

public LettuceReactiveHashCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveHashCommands.

Parameters:

connection - must not be null.

Method Detail

hSet

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HSetCommand>> hSet(org.reactivestreams.Publisher<ReactiveHashCommands.HSetCommand> commands)

Description copied from interface: ReactiveHashCommands

Set the value of a hash field.

Specified by:

hSet in interface ReactiveHashCommands

Parameters:

commands - must not be null.

Returns:

hMGet

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveHashCommands.HGetCommand,ByteBuffer>> hMGet(org.reactivestreams.Publisher<ReactiveHashCommands.HGetCommand> commands)

Description copied from interface: ReactiveHashCommands

Get values for given fields from hash at key.

Specified by:

hMGet in interface ReactiveHashCommands

Parameters:

commands - must not be null.

Returns:

hExists

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HExistsCommand>> hExists(org.reactivestreams.Publisher<ReactiveHashCommands.HExistsCommand> commands)

Description copied from interface: ReactiveHashCommands

Determine if given hash field exists.

Specified by:

hExists in interface ReactiveHashCommands

Returns:

hDel

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HDelCommand,Long>> hDel(org.reactivestreams.Publisher<ReactiveHashCommands.HDelCommand> commands)

Description copied from interface: ReactiveHashCommands

Delete given hash fields.

Specified by:

hDel in interface ReactiveHashCommands

Parameters:

commands - must not be null.

Returns:

hLen

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> hLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveHashCommands

Get size of hash at key.

Specified by:

hLen in interface ReactiveHashCommands

Parameters:

commands - must not be null.

Returns:

hKeys

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveRedisConnection.KeyCommand,ByteBuffer>> hKeys(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveHashCommands

Get key set (fields) of hash at key.

Specified by:

hKeys in interface ReactiveHashCommands

Parameters:

commands - must not be null.

Returns:

hVals

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveRedisConnection.KeyCommand,ByteBuffer>> hVals(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveHashCommands

Get entry set (values) of hash at key.

Specified by:

hVals in interface ReactiveHashCommands

Parameters:

commands - must not be null.

Returns:

hGetAll

public reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,Map<ByteBuffer,ByteBuffer>>> hGetAll(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveHashCommands

Get entire hash stored at key.

Specified by:

hGetAll in interface ReactiveHashCommands

Parameters:

commands - must not be null.

Returns: