Package io.lettuce.core.sentinel.api.reactive

Interface RedisSentinelReactiveCommands<K,​V>

  • Type Parameters:
    K - Key type.
    V - Value type.
    All Known Implementing Classes:
    RedisSentinelReactiveCommandsImpl
    public interface RedisSentinelReactiveCommands<K,​V>
    Reactive executed commands for Redis Sentinel.
    Since:
    4.0
    Author:
    Mark Paluch
    Generated class:
    by io.lettuce.apigenerator.CreateReactiveApi

    • Method Detail

      • getMasterAddrByName

        Mono<SocketAddress> getMasterAddrByName​(K key)
        Return the ip and port number of the master with that name.
        Parameters:
        key - the key.
        Returns:
        SocketAddress.

      • masters

        Flux<Map<K,​V>> masters()
        Enumerates all the monitored masters and their states.
        Returns:
        Map<K, V>>.

      • master

        Mono<Map<K,​V>> master​(K key)
        Show the state and info of the specified master.
        Parameters:
        key - the key.
        Returns:
        Map<K, V>.

      • slaves

        @Deprecated
Flux<Map<K,​V>> slaves​(K key)
        Deprecated.
        since 6.2, use #replicas(Object) instead.
        Provides a list of replicas for the master with the specified name.
        Parameters:
        key - the key.
        Returns:
        Map<K, V>.

      • reset

        Mono<Long> reset​(K key)
        This command will reset all the masters with matching name.
        Parameters:
        key - the key.
        Returns:
        Long.

      • replicas

        Flux<Map<K,​V>> replicas​(K key)
        Provides a list of replicas for the master with the specified name.
        Parameters:
        key - the key.
        Returns:
        Map<K, V>.
        Since:
        6.2

      • failover

        Mono<String> failover​(K key)
        Perform a failover.
        Parameters:
        key - the master id.
        Returns:
        String.

      • monitor

        Mono<String> monitor​(K key,
                     String ip,
                     int port,
                     int quorum)
        This command tells the Sentinel to start monitoring a new master with the specified name, ip, port, and quorum.
        Parameters:
        key - the key.
        ip - the IP address.
        port - the port.
        quorum - the quorum count.
        Returns:
        String.

      • set

        Mono<String> set​(K key,
                 String option,
                 V value)
        Multiple option / value pairs can be specified (or none at all).
        Parameters:
        key - the key.
        option - the option.
        value - the value.
        Returns:
        String simple-string-reply OK if SET was executed correctly.

      • remove

        Mono<String> remove​(K key)
        remove the specified master.
        Parameters:
        key - the key.
        Returns:
        String.

      • clientGetname

        Mono<K> clientGetname()
        Get the current connection name.
        Returns:
        K bulk-string-reply The connection name, or a null bulk reply if no name is set.

      • clientSetname

        Mono<String> clientSetname​(K name)
        Set the current connection name.
        Parameters:
        name - the client name.
        Returns:
        simple-string-reply OK if the connection name was successfully set.

      • clientSetinfo

        Mono<String> clientSetinfo​(String key,
                           String value)
        Assign various info attributes to the current connection.
        Parameters:
        key - the key.
        value - the value.
        Returns:
        simple-string-reply OK if the connection name was successfully set.
        Since:
        6.3

      • clientKill

        Mono<String> clientKill​(String addr)
        Kill the connection of a client identified by ip:port.
        Parameters:
        addr - ip:port.
        Returns:
        String simple-string-reply OK if the connection exists and has been closed.

      • clientKill

        Mono<Long> clientKill​(KillArgs killArgs)
        Kill connections of clients which are filtered by killArgs.
        Parameters:
        killArgs - args for the kill operation.
        Returns:
        Long integer-reply number of killed connections.

      • clientPause

        Mono<String> clientPause​(long timeout)
        Stop processing commands from clients for some time.
        Parameters:
        timeout - the timeout value in milliseconds.
        Returns:
        String simple-string-reply The command returns OK or an error if the timeout is invalid.

      • clientList

        Mono<String> clientList()
        Get the list of client connections.
        Returns:
        String bulk-string-reply a unique string, formatted as follows: One client connection per line (separated by LF), each line is composed of a succession of property=value fields separated by a space character.

      • clientList

        Mono<String> clientList​(ClientListArgs clientListArgs)
        Get the list of client connections which are filtered by clientListArgs.
        Returns:
        String bulk-string-reply a unique string, formatted as follows: One client connection per line (separated by LF), each line is composed of a succession of property=value fields separated by a space character.
        Since:
        6.3

      • clientInfo

        Mono<String> clientInfo()
        Get the list of the current client connection.
        Returns:
        String bulk-string-reply a unique string, formatted as a succession of property=value fields separated by a space character.
        Since:
        6.3

      • info

        Mono<String> info()
        Get information and statistics about the server.
        Returns:
        String bulk-string-reply as a collection of text lines.

      • info

        Mono<String> info​(String section)
        Get information and statistics about the server.
        Parameters:
        section - the section type: string.
        Returns:
        String bulk-string-reply as a collection of text lines.

      • ping

        Mono<String> ping()
        Ping the server.
        Returns:
        String simple-string-reply.

      • dispatch

        <T> Flux<T> dispatch​(ProtocolKeyword type,
                     CommandOutput<K,​V,​?> output)
        Dispatch a command to the Redis Server. Please note the command output type must fit to the command response.
        Type Parameters:
        T - response type.
        Parameters:
        type - the command, must not be null.
        output - the command output, must not be null.
        Returns:
        the command response.
        Since:
        6.0.2

      • dispatch

        <T> Flux<T> dispatch​(ProtocolKeyword type,
                     CommandOutput<K,​V,​?> output,
                     CommandArgs<K,​V> args)
        Dispatch a command to the Redis Server. Please note the command output type must fit to the command response.
        Type Parameters:
        T - response type.
        Parameters:
        type - the command, must not be null.
        output - the command output, must not be null.
        args - the command arguments, must not be null.
        Returns:
        the command response.
        Since:
        6.0.2

      • isOpen

        boolean isOpen()
        Returns:
        true if the connection is open (connected and not closed).