Package | Description |
---|---|
io.lettuce.core |
The Redis client package containing
RedisClient for Redis Standalone and Redis Sentinel operations. |
io.lettuce.core.api.async |
Standalone Redis API for asynchronous executed commands.
|
io.lettuce.core.api.reactive |
Standalone Redis API for reactive command execution.
|
io.lettuce.core.api.sync |
Standalone Redis API for synchronous executed commands.
|
io.lettuce.core.cluster.api.async |
Redis Cluster API for asynchronous executed commands.
|
io.lettuce.core.cluster.api.sync |
Redis Cluster API for synchronous executed commands.
|
Modifier and Type | Method and Description |
---|---|
XAddArgs |
XAddArgs.approximateTrimming()
Apply efficient trimming for capped streams using the
~ flag. |
XAddArgs |
XAddArgs.approximateTrimming(boolean approximateTrimming)
Apply efficient trimming for capped streams using the
~ flag. |
XAddArgs |
XAddArgs.exactTrimming()
Apply exact trimming for capped streams using the
= flag. |
XAddArgs |
XAddArgs.exactTrimming(boolean exactTrimming)
Apply exact trimming for capped streams using the
= flag. |
XAddArgs |
XAddArgs.id(String id)
Specify the message
id . |
XAddArgs |
XAddArgs.limit(long limit)
The maximum number of entries to trim.
|
XAddArgs |
XAddArgs.maxlen(long maxlen)
Limit stream to
maxlen entries. |
static XAddArgs |
XAddArgs.Builder.maxlen(long count)
Creates new
XAddArgs and setting MAXLEN. |
XAddArgs |
XAddArgs.minId(String minid)
Limit stream entries by message Id.
|
static XAddArgs |
XAddArgs.Builder.minId(String minid)
Creates new
XAddArgs and setting MINID. |
XAddArgs |
XAddArgs.nomkstream()
Do add the message if the stream does not already exist.
|
static XAddArgs |
XAddArgs.Builder.nomkstream()
Creates new
XAddArgs and setting NOMKSTREAM. |
XAddArgs |
XAddArgs.nomkstream(boolean nomkstream)
Do add the message if the stream does not already exist.
|
Modifier and Type | Method and Description |
---|---|
RedisFuture<String> |
AbstractRedisAsyncCommands.xadd(K key,
XAddArgs args,
Map<K,V> body) |
Mono<String> |
AbstractRedisReactiveCommands.xadd(K key,
XAddArgs args,
Map<K,V> body) |
RedisFuture<String> |
AbstractRedisAsyncCommands.xadd(K key,
XAddArgs args,
Object... keysAndValues) |
Mono<String> |
AbstractRedisReactiveCommands.xadd(K key,
XAddArgs args,
Object... keysAndValues) |
Modifier and Type | Method and Description |
---|---|
RedisFuture<String> |
RedisStreamAsyncCommands.xadd(K key,
XAddArgs args,
Map<K,V> body)
Append a message to the stream
key . |
RedisFuture<String> |
RedisStreamAsyncCommands.xadd(K key,
XAddArgs args,
Object... keysAndValues)
Append a message to the stream
key . |
Modifier and Type | Method and Description |
---|---|
Mono<String> |
RedisStreamReactiveCommands.xadd(K key,
XAddArgs args,
Map<K,V> body)
Append a message to the stream
key . |
Mono<String> |
RedisStreamReactiveCommands.xadd(K key,
XAddArgs args,
Object... keysAndValues)
Append a message to the stream
key . |
Modifier and Type | Method and Description |
---|---|
String |
RedisStreamCommands.xadd(K key,
XAddArgs args,
Map<K,V> body)
Append a message to the stream
key . |
String |
RedisStreamCommands.xadd(K key,
XAddArgs args,
Object... keysAndValues)
Append a message to the stream
key . |
Modifier and Type | Method and Description |
---|---|
AsyncExecutions<String> |
NodeSelectionStreamAsyncCommands.xadd(K key,
XAddArgs args,
Map<K,V> body)
Append a message to the stream
key . |
AsyncExecutions<String> |
NodeSelectionStreamAsyncCommands.xadd(K key,
XAddArgs args,
Object... keysAndValues)
Append a message to the stream
key . |
Modifier and Type | Method and Description |
---|---|
Executions<String> |
NodeSelectionStreamCommands.xadd(K key,
XAddArgs args,
Map<K,V> body)
Append a message to the stream
key . |
Executions<String> |
NodeSelectionStreamCommands.xadd(K key,
XAddArgs args,
Object... keysAndValues)
Append a message to the stream
key . |
Copyright © 2023 lettuce.io. All rights reserved.