K
- Key type.V
- Value type.public interface BaseNodeSelectionCommands<K,V>
Modifier and Type | Method and Description |
---|---|
Executions<V> |
echo(V msg)
Echo the given string.
|
Executions<String> |
ping()
Ping the server.
|
Executions<Long> |
publish(K channel,
V message)
Post a message to a channel.
|
Executions<List<K>> |
pubsubChannels()
Lists the currently *active channels*.
|
Executions<List<K>> |
pubsubChannels(K channel)
Lists the currently *active channels*.
|
Executions<Long> |
pubsubNumpat()
Returns the number of subscriptions to patterns.
|
Executions<Map<K,Long>> |
pubsubNumsub(K... channels)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.
|
Executions<String> |
quit()
Instructs Redis to disconnect the connection.
|
Executions<List<Object>> |
role()
Return the role of the instance in the context of replication.
|
Executions<Long> |
waitForReplication(int replicas,
long timeout)
Wait for replication.
|
Executions<Long> publish(K channel, V message)
channel
- the channel type: key.message
- the message type: value.Executions<List<K>> pubsubChannels()
Executions<List<K>> pubsubChannels(K channel)
channel
- the key.Executions<Map<K,Long>> pubsubNumsub(K... channels)
channels
- channel keys.Executions<Long> pubsubNumpat()
Executions<V> echo(V msg)
msg
- the message type: value.Executions<List<Object>> role()
Executions<String> ping()
Executions<String> quit()
StatefulConnection.close()
to close connections and
release resources.Executions<Long> waitForReplication(int replicas, long timeout)
replicas
- minimum number of replicas.timeout
- timeout in milliseconds.Copyright © 2023 lettuce.io. All rights reserved.