Package org.springframework.data.redis.connection

Interface ReactiveStringCommands

All Known Subinterfaces:

ReactiveClusterStringCommands

public interface ReactiveStringCommands

Redis String commands executed using reactive infrastructure.

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ReactiveStringCommands.AppendCommand	APPEND command parameters.
static class	ReactiveStringCommands.BitCountCommand	BITCOUNT command parameters.
static class	ReactiveStringCommands.BitFieldCommand	BITFIELD command parameters.
static class	ReactiveStringCommands.BitOpCommand	BITOP command parameters.
static class	ReactiveStringCommands.BitPosCommand
static class	ReactiveStringCommands.GetBitCommand	GETBIT command parameters.
static class	ReactiveStringCommands.GetExCommand	ReactiveRedisConnection.Command for GETEX.
static class	ReactiveStringCommands.MSetCommand	MSET command parameters.
static class	ReactiveStringCommands.SetBitCommand	SETBIT command parameters.
static class	ReactiveStringCommands.SetCommand	SET command parameters.
static class	ReactiveStringCommands.SetRangeCommand	SETRANGE command parameters.

Method Summary

Modifier and Type	Method	Description
default reactor.core.publisher.Mono<Long>	append(ByteBuffer key, ByteBuffer value)	Append a value to key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,Long>>	append(org.reactivestreams.Publisher<ReactiveStringCommands.AppendCommand> commands)	Append a ReactiveStringCommands.AppendCommand.getValue() to the ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.Mono<Long>	bitCount(ByteBuffer key)	Count the number of set bits (population counting) in value stored at key.
default reactor.core.publisher.Mono<Long>	bitCount(ByteBuffer key, long start, long end)	Count the number of set bits (population counting) of value stored at key between start and end.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitCountCommand,Long>>	bitCount(org.reactivestreams.Publisher<ReactiveStringCommands.BitCountCommand> commands)	Count the number of set bits (population counting) of value stored at key between start and end.
default reactor.core.publisher.Mono<List<Long>>	bitField(ByteBuffer key, BitFieldSubCommands subCommands)	Get / Manipulate specific integer fields of varying bit widths and arbitrary non (necessary) aligned offset stored at a given key.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveStringCommands.BitFieldCommand,Long>>	bitField(org.reactivestreams.Publisher<ReactiveStringCommands.BitFieldCommand> commands)	Get / Manipulate specific integer fields of varying bit widths and arbitrary non (necessary) aligned offset stored at a given key.
default reactor.core.publisher.Mono<Long>	bitOp(Collection<ByteBuffer> keys, RedisStringCommands.BitOperation bitOp, ByteBuffer destination)	Perform bitwise operations between strings.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitOpCommand,Long>>	bitOp(org.reactivestreams.Publisher<ReactiveStringCommands.BitOpCommand> commands)	Perform bitwise operations between strings.
default reactor.core.publisher.Mono<Long>	bitPos(ByteBuffer key, boolean bit)	Return the position of the first bit set to given bit in a string.
default reactor.core.publisher.Mono<Long>	bitPos(ByteBuffer key, boolean bit, Range<Long> range)	Return the position of the first bit set to given bit in a string.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitPosCommand,Long>>	bitPos(org.reactivestreams.Publisher<ReactiveStringCommands.BitPosCommand> commands)	Emmit the the position of the first bit set to given bit in a string.
default reactor.core.publisher.Mono<ByteBuffer>	get(ByteBuffer key)	Get single element stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>	get(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys)	Get elements one by one.
default reactor.core.publisher.Mono<Boolean>	getBit(ByteBuffer key, long offset)	Get the bit value at offset of value at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.GetBitCommand>>	getBit(org.reactivestreams.Publisher<ReactiveStringCommands.GetBitCommand> commands)	Get the bit value at offset of value at key.
default reactor.core.publisher.Mono<ByteBuffer>	getDel(ByteBuffer key)	Return the value at key and delete the key.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>	getDel(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Return the value at key and delete the key.
default reactor.core.publisher.Mono<ByteBuffer>	getEx(ByteBuffer key, Expiration expiration)	Return the value at key and expire the key by applying Expiration.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.GetExCommand>>	getEx(org.reactivestreams.Publisher<ReactiveStringCommands.GetExCommand> commands)	Return the value at key and expire the key by applying Expiration.
default reactor.core.publisher.Mono<ByteBuffer>	getRange(ByteBuffer key, long start, long end)	Get a substring of value of key between start and end.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.RangeCommand>>	getRange(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands)	Get a substring of value of key between start and end.
default reactor.core.publisher.Mono<ByteBuffer>	getSet(ByteBuffer key, ByteBuffer value)	Set value for key and return the existing value.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.SetCommand>>	getSet(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)	Set value for key and return the existing value one by one.
default reactor.core.publisher.Mono<List<ByteBuffer>>	mGet(List<ByteBuffer> keys)	Get multiple values in one batch.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<List<ByteBuffer>,ByteBuffer>>	mGet(org.reactivestreams.Publisher<List<ByteBuffer>> keysets)	Get multiple values at for keysets in batches.
default reactor.core.publisher.Mono<Boolean>	mSet(Map<ByteBuffer,ByteBuffer> keyValuePairs)	Set multiple keys to multiple values using key-value pairs provided in tuple.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>>	mSet(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> commands)	Set multiple keys to multiple values using key-value pairs provided in commands.
default reactor.core.publisher.Mono<Boolean>	mSetNX(Map<ByteBuffer,ByteBuffer> keyValuePairs)	Set multiple keys to multiple values using key-value pairs provided in keyValuePairs only if the provided key does not exist.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>>	mSetNX(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> source)	Set multiple keys to multiple values using key-value pairs provided in tuples only if the provided key does not exist.
default reactor.core.publisher.Mono<Boolean>	pSetEX(ByteBuffer key, ByteBuffer value, Expiration expireTimeout)	Set key value pair and Expiration.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>	pSetEX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)	Set key value pairs and Expiration.
default reactor.core.publisher.Mono<Boolean>	set(ByteBuffer key, ByteBuffer value)	Set value for key.
default reactor.core.publisher.Mono<Boolean>	set(ByteBuffer key, ByteBuffer value, Expiration expiration, RedisStringCommands.SetOption option)	Set value for key with expiration and options.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>	set(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)	Set each and every item separately by invoking ReactiveStringCommands.SetCommand.
default reactor.core.publisher.Mono<Boolean>	setBit(ByteBuffer key, long offset, boolean value)	Sets the bit at offset in value stored at key and return the original value.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetBitCommand>>	setBit(org.reactivestreams.Publisher<ReactiveStringCommands.SetBitCommand> commands)	Sets the bit at offset in value stored at key and return the original value.
default reactor.core.publisher.Mono<Boolean>	setEX(ByteBuffer key, ByteBuffer value, Expiration expireTimeout)	Set key value pair and Expiration.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>	setEX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)	Set key value pairs and Expiration.
default reactor.core.publisher.Mono<Boolean>	setNX(ByteBuffer key, ByteBuffer value)	Set value for key, only if key does not exist.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>	setNX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> values)	Set key value pairs, only if key does not exist.
default reactor.core.publisher.Mono<Long>	setRange(ByteBuffer key, ByteBuffer value, long offset)	Overwrite parts of key starting at the specified offset with given value.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.SetRangeCommand,Long>>	setRange(org.reactivestreams.Publisher<ReactiveStringCommands.SetRangeCommand> commands)	Overwrite parts of ReactiveRedisConnection.KeyCommand.key starting at the specified offset with given ReactiveStringCommands.SetRangeCommand.value.
default reactor.core.publisher.Mono<Long>	strLen(ByteBuffer key)	Get the length of the value stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	strLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys)	Get the length of the value stored at key.

Method Details

set

default reactor.core.publisher.Mono<Boolean> set(ByteBuffer key,
 ByteBuffer value)

Set value for key.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: SET

set

default reactor.core.publisher.Mono<Boolean> set(ByteBuffer key,
 ByteBuffer value,
 Expiration expiration,
 RedisStringCommands.SetOption option)

Set value for key with expiration and options.

Parameters:

key - must not be null.

value - must not be null.

expiration - must not be null. Use Expiration.persistent() for no expiration time or Expiration.keepTtl() to keep the existing.

option - must not be null.

Returns:

See Also:

• Redis Documentation: SET

set

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>> set(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)

Set each and every item separately by invoking ReactiveStringCommands.SetCommand.

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.BooleanResponse holding the ReactiveStringCommands.SetCommand along with the command result.

See Also:

• Redis Documentation: SET

get

default reactor.core.publisher.Mono<ByteBuffer> get(ByteBuffer key)

Get single element stored at key.

Parameters:

key - must not be null.

Returns:

Mono.empty() in case key does not exist.

See Also:

• Redis Documentation: GET

get

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>> get(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys)

Get elements one by one.

Parameters:

keys - must not be null.

Returns:

Flux of ReactiveRedisConnection.ByteBufferResponse holding the key to get along with the value retrieved.

See Also:

• Redis Documentation: GET

getDel

default reactor.core.publisher.Mono<ByteBuffer> getDel(ByteBuffer key)

Return the value at key and delete the key.

Parameters:

key - must not be null.

Returns:

Mono.empty() in case key does not exist.

Since:

2.6

See Also:

• Redis Documentation: GETDEL

getDel

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>> getDel(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Return the value at key and delete the key.

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.ByteBufferResponse holding the key to get along with the value retrieved.

Since:

2.6

See Also:

• Redis Documentation: GETDEL

getEx

default reactor.core.publisher.Mono<ByteBuffer> getEx(ByteBuffer key,
 Expiration expiration)

Return the value at key and expire the key by applying Expiration.

Parameters:

key - must not be null.

expiration - must not be null.

Returns:

Mono.empty() in case key does not exist.

Since:

2.6

See Also:

• Redis Documentation: GETEX

getEx

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.GetExCommand>> getEx(org.reactivestreams.Publisher<ReactiveStringCommands.GetExCommand> commands)

Return the value at key and expire the key by applying Expiration.

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.ByteBufferResponse holding the key to get along with the value retrieved.

Since:

2.6

See Also:

• Redis Documentation: GETEX

getSet

default reactor.core.publisher.Mono<ByteBuffer> getSet(ByteBuffer key,
 ByteBuffer value)

Set value for key and return the existing value.

Parameters:

key - must not be null.

value - must not be null.

Returns:

Mono.empty() if key did not exist.

See Also:

• Redis Documentation: GETSET

getSet

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.SetCommand>> getSet(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)

Set value for key and return the existing value one by one.

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.ByteBufferResponse holding the ReactiveStringCommands.SetCommand along with the previously existing value.

See Also:

• Redis Documentation: GETSET

mGet

default reactor.core.publisher.Mono<List<ByteBuffer>> mGet(List<ByteBuffer> keys)

Get multiple values in one batch. Values are in the order of the requested keys. Absent field values are represented using null in the resulting List.

Parameters:

keys - must not be null.

Returns:

See Also:

• Redis Documentation: MGET

mGet

reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<List<ByteBuffer>,ByteBuffer>> mGet(org.reactivestreams.Publisher<List<ByteBuffer>> keysets)

Get multiple values at for keysets in batches. Values are in the order of the requested keys. Absent field values are represented using null in the resulting List.

Parameters:

keysets - must not be null.

Returns:

See Also:

• Redis Documentation: MGET

setNX

default reactor.core.publisher.Mono<Boolean> setNX(ByteBuffer key,
 ByteBuffer value)

Set value for key, only if key does not exist.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: SETNX

setNX

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>> setNX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> values)

Set key value pairs, only if key does not exist.

Parameters:

values - must not be null.

Returns:

See Also:

• Redis Documentation: SETNX

setEX

default reactor.core.publisher.Mono<Boolean> setEX(ByteBuffer key,
 ByteBuffer value,
 Expiration expireTimeout)

Set key value pair and Expiration.

Parameters:

key - must not be null.

value - must not be null.

expireTimeout - must not be null.

Returns:

See Also:

• Redis Documentation: SETEX

setEX

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>> setEX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)

Set key value pairs and Expiration.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SETEX

pSetEX

default reactor.core.publisher.Mono<Boolean> pSetEX(ByteBuffer key,
 ByteBuffer value,
 Expiration expireTimeout)

Set key value pair and Expiration.

Parameters:

key - must not be null.

value - must not be null.

expireTimeout - must not be null.

Returns:

See Also:

• Redis Documentation: PSETEX

pSetEX

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>> pSetEX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)

Set key value pairs and Expiration.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: PSETEX

mSet

default reactor.core.publisher.Mono<Boolean> mSet(Map<ByteBuffer,ByteBuffer> keyValuePairs)

Set multiple keys to multiple values using key-value pairs provided in tuple.

Parameters:

keyValuePairs - must not be null.

Returns:

See Also:

• Redis Documentation: MSET

mSet

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>> mSet(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> commands)

Set multiple keys to multiple values using key-value pairs provided in commands.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: MSET

mSetNX

default reactor.core.publisher.Mono<Boolean> mSetNX(Map<ByteBuffer,ByteBuffer> keyValuePairs)

Set multiple keys to multiple values using key-value pairs provided in keyValuePairs only if the provided key does not exist.

Parameters:

keyValuePairs - must not be null.

Returns:

See Also:

• Redis Documentation: MSETNX

mSetNX

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>> mSetNX(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> source)

Set multiple keys to multiple values using key-value pairs provided in tuples only if the provided key does not exist.

Parameters:

source - must not be null.

Returns:

See Also:

• Redis Documentation: MSETNX

append

default reactor.core.publisher.Mono<Long> append(ByteBuffer key,
 ByteBuffer value)

Append a value to key.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: APPEND

append

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,Long>> append(org.reactivestreams.Publisher<ReactiveStringCommands.AppendCommand> commands)

Append a ReactiveStringCommands.AppendCommand.getValue() to the ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: APPEND

getRange

default reactor.core.publisher.Mono<ByteBuffer> getRange(ByteBuffer key,
 long start,
 long end)

Get a substring of value of key between start and end.

Parameters:

key - must not be null.

start -

end -

Returns:

See Also:

• Redis Documentation: GETRANGE

getRange

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.RangeCommand>> getRange(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands)

Get a substring of value of key between start and end.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: GETRANGE

setRange

default reactor.core.publisher.Mono<Long> setRange(ByteBuffer key,
 ByteBuffer value,
 long offset)

Overwrite parts of key starting at the specified offset with given value.

Parameters:

key - must not be null.

value - must not be null.

offset -

Returns:

See Also:

• Redis Documentation: SETRANGE

setRange

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.SetRangeCommand,Long>> setRange(org.reactivestreams.Publisher<ReactiveStringCommands.SetRangeCommand> commands)

Overwrite parts of ReactiveRedisConnection.KeyCommand.key starting at the specified offset with given ReactiveStringCommands.SetRangeCommand.value.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SETRANGE

getBit

default reactor.core.publisher.Mono<Boolean> getBit(ByteBuffer key,
 long offset)

Get the bit value at offset of value at key.

Parameters:

key - must not be null.

offset -

Returns:

See Also:

• Redis Documentation: GETBIT

getBit

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.GetBitCommand>> getBit(org.reactivestreams.Publisher<ReactiveStringCommands.GetBitCommand> commands)

Get the bit value at offset of value at key.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: GETBIT

setBit

default reactor.core.publisher.Mono<Boolean> setBit(ByteBuffer key,
 long offset,
 boolean value)

Sets the bit at offset in value stored at key and return the original value.

Parameters:

key - must not be null.

offset -

value -

Returns:

setBit

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetBitCommand>> setBit(org.reactivestreams.Publisher<ReactiveStringCommands.SetBitCommand> commands)

Sets the bit at offset in value stored at key and return the original value.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: SETBIT

bitCount

default reactor.core.publisher.Mono<Long> bitCount(ByteBuffer key)

Count the number of set bits (population counting) in value stored at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: BITCOUNT

bitCount

default reactor.core.publisher.Mono<Long> bitCount(ByteBuffer key,
 long start,
 long end)

Count the number of set bits (population counting) of value stored at key between start and end.

Parameters:

key - must not be null.

start -

end -

Returns:

See Also:

• Redis Documentation: BITCOUNT

bitCount

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitCountCommand,Long>> bitCount(org.reactivestreams.Publisher<ReactiveStringCommands.BitCountCommand> commands)

Count the number of set bits (population counting) of value stored at key between start and end.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: BITCOUNT

bitField

default reactor.core.publisher.Mono<List<Long>> bitField(ByteBuffer key,
 BitFieldSubCommands subCommands)

Get / Manipulate specific integer fields of varying bit widths and arbitrary non (necessary) aligned offset stored at a given key.

Parameters:

key - must not be null.

subCommands -

Returns:

Since:

2.1

See Also:

• Redis Documentation: BITFIELD

bitField

reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveStringCommands.BitFieldCommand,Long>> bitField(org.reactivestreams.Publisher<ReactiveStringCommands.BitFieldCommand> commands)

Get / Manipulate specific integer fields of varying bit widths and arbitrary non (necessary) aligned offset stored at a given key.

Parameters:

commands - must not be null.

Returns:

Since:

2.1

See Also:

• Redis Documentation: BITFIELD

bitOp

default reactor.core.publisher.Mono<Long> bitOp(Collection<ByteBuffer> keys,
 RedisStringCommands.BitOperation bitOp,
 ByteBuffer destination)

Perform bitwise operations between strings.

Parameters:

keys - must not be null.

bitOp - must not be null.

destination - must not be null.

Returns:

See Also:

• Redis Documentation: BITOP

bitOp

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitOpCommand,Long>> bitOp(org.reactivestreams.Publisher<ReactiveStringCommands.BitOpCommand> commands)

Perform bitwise operations between strings.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: BITOP

bitPos

default reactor.core.publisher.Mono<Long> bitPos(ByteBuffer key,
 boolean bit)

Return the position of the first bit set to given bit in a string.

Parameters:

key - the key holding the actual String.

bit - the bit value to look for.

Returns:

Mono emitting result when ready.

Since:

2.1

bitPos

default reactor.core.publisher.Mono<Long> bitPos(ByteBuffer key,
 boolean bit,
 Range<Long> range)

Return the position of the first bit set to given bit in a string. Range start and end can contain negative values in order to index bytes starting from the end of the string, where -1 is the last byte, -2 is the penultimate.

Parameters:

key - the key holding the actual String.

bit - the bit value to look for.

range - must not be null. Use Range.unbounded() to not limit search.

Returns:

Mono emitting result when ready.

Since:

2.1

bitPos

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitPosCommand,Long>> bitPos(org.reactivestreams.Publisher<ReactiveStringCommands.BitPosCommand> commands)

Emmit the the position of the first bit set to given bit in a string. Get the length of the value stored at key.

Parameters:

commands - must not be null.

Returns:

Flux emitting results when ready.

Since:

2.1

strLen

default reactor.core.publisher.Mono<Long> strLen(ByteBuffer key)

Get the length of the value stored at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: STRLEN

strLen

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> strLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys)

Get the length of the value stored at key.

Parameters:

keys - must not be null.

Returns:

See Also:

• Redis Documentation: STRLEN