Module: Valkey::Commands::ConnectionCommands

Included in:
Valkey::Commands
Defined in:
lib/valkey/commands/connection_commands.rb

Overview

This module contains commands related to connection management.

See Also:

Instance Method Summary collapse

Instance Method Details

#auth(*args) ⇒ String

Authenticate to the server.

Parameters:

  • args (Array<String>) —

    includes both username and password or only password

Returns:

  • (String) —

    OK



15
16
17
 
# File 'lib/valkey/commands/connection_commands.rb', line 15

def auth(*args)
  send_command(RequestType::AUTH, args)
end

#client(subcommand, *args) ⇒ Object

Send a generic CLIENT subcommand.

Examples:

client(:id)                  # => 12345
client(:set_name, "my_app")  # => "OK"
client(:list)                # => [{"id" => "1", ...}, ...]

Parameters:

  • subcommand (Symbol, String) —

    The CLIENT subcommand to run, e.g. :list, :id, :kill, etc.

  • args (Array) —

    Arguments for the subcommand

Returns:

  • (Object) —

    Depends on subcommand



84
85
86
 
# File 'lib/valkey/commands/connection_commands.rb', line 84

def client(subcommand, *args)
  public_send("client_#{subcommand.to_s.downcase}", *args)
end

#client_get_name ⇒ String?

Get the current client's name.

Returns:

  • (String, nil) —

    Client name or nil if not set



99
100
101
 
# File 'lib/valkey/commands/connection_commands.rb', line 99

def client_get_name
  send_command(RequestType::CLIENT_GET_NAME)
end

#client_id(route: nil) ⇒ Integer

Get the current client's ID.

Parameters:

  • route (Valkey::Route, nil) (defaults to: nil) —

    cluster routing. When routed, may return a Hash of node => value.

Returns:

  • (Integer) 


92
93
94
 
# File 'lib/valkey/commands/connection_commands.rb', line 92

def client_id(route: nil)
  send_command(RequestType::CLIENT_ID, [], route: route)
end

#client_info ⇒ String

Get information about the current client connection.

Returns:

  • (String) —

    Client connection information



139
140
141
 
# File 'lib/valkey/commands/connection_commands.rb', line 139

def client_info
  send_command(RequestType::CLIENT_INFO)
end

#client_kill(addr = nil, **options) ⇒ Integer

Kill client connections.

Parameters:

  • addr (String) (defaults to: nil) —

    Client address (ip:port)

  • options (Hash) —

    Optional filters (id, type, user, addr, laddr, skipme)

Returns:

  • (Integer) —

    Number of clients killed



148
149
150
151
152
153
154
 
# File 'lib/valkey/commands/connection_commands.rb', line 148

def client_kill(addr = nil, **options)
  if addr && options.empty?
    send_command(RequestType::CLIENT_KILL_SIMPLE, [addr])
  else
    send_command(RequestType::CLIENT_KILL, build_client_kill_args(addr, options))
  end
end

#client_kill_simple(addr) ⇒ String

Kill a client connection by address (simple form).

Parameters:

  • addr (String) —

    Client address (ip:port)

Returns:

  • (String) —

    OK



160
161
162
 
# File 'lib/valkey/commands/connection_commands.rb', line 160

def client_kill_simple(addr)
  send_command(RequestType::CLIENT_KILL_SIMPLE, [addr])
end

#client_list(type: nil, ids: nil) ⇒ Array<Hash>

Get a list of client connections.

Parameters:

  • type (String) (defaults to: nil) —

    Optional filter by client type (normal, master, slave, pubsub)

  • ids (Array<String>) (defaults to: nil) —

    Optional filter by client IDs

Returns:

  • (Array<Hash>) —

    List of clients, each represented as a Hash of attributes



116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
 
# File 'lib/valkey/commands/connection_commands.rb', line 116

def client_list(type: nil, ids: nil)
  args = []

  args << "TYPE" << type if type

  if ids
    args << "ID"
    args.concat(Array(ids))
  end

  send_command(RequestType::CLIENT_LIST, args) do |reply|
    reply.lines.map do |line|
      line.chomp.split.each_with_object({}) do |pair, hash|
        key, value = pair.split("=", 2)
        hash[key] = value || ""
      end
    end
  end
end

#client_no_evict(mode) ⇒ String

Enable/disable client no-evict mode.

Parameters:

  • mode (String) —

    Mode (ON, OFF)

Returns:

  • (String) —

    OK



254
255
256
 
# File 'lib/valkey/commands/connection_commands.rb', line 254

def client_no_evict(mode)
  send_command(RequestType::CLIENT_NO_EVICT, [mode.to_s.upcase])
end

#client_no_touch(mode) ⇒ String

Enable/disable client no-touch mode.

Parameters:

  • mode (String) —

    Mode (ON, OFF)

Returns:

  • (String) —

    OK



262
263
264
 
# File 'lib/valkey/commands/connection_commands.rb', line 262

def client_no_touch(mode)
  send_command(RequestType::CLIENT_NO_TOUCH, [mode.to_s.upcase])
end

#client_pause(timeout, mode = nil) ⇒ String

Pause client processing.

Parameters:

  • timeout (Integer) —

    Pause duration in milliseconds

  • mode (String) (defaults to: nil) —

    Optional mode (WRITE, ALL)

Returns:

  • (String) —

    OK



189
190
191
192
193
 
# File 'lib/valkey/commands/connection_commands.rb', line 189

def client_pause(timeout, mode = nil)
  args = [timeout]
  args << mode if mode
  send_command(RequestType::CLIENT_PAUSE, args)
end

#client_set_info(attr, value) ⇒ String

Set client connection information.

Parameters:

  • attr (String) —

    Attribute to set (lib-name, lib-ver)

  • value (String) —

    Value to set for the attribute

Returns:

  • (String) —

    OK



208
209
210
 
# File 'lib/valkey/commands/connection_commands.rb', line 208

def client_set_info(attr, value)
  send_command(RequestType::CLIENT_SET_INFO, [attr, value])
end

#client_set_name(name) ⇒ String

Set the current client's name.

Parameters:

  • name (String) —

    New name for the client connection

Returns:

  • (String) —

    OK



107
108
109
 
# File 'lib/valkey/commands/connection_commands.rb', line 107

def client_set_name(name)
  send_command(RequestType::CLIENT_SET_NAME, [name])
end

#client_unpause(route: nil) ⇒ String

Unpause client processing.

Parameters:

  • route (Valkey::Route, nil) (defaults to: nil) —

    cluster routing.

Returns:

  • (String) —

    OK



199
200
201
 
# File 'lib/valkey/commands/connection_commands.rb', line 199

def client_unpause(route: nil)
  send_command(RequestType::CLIENT_UNPAUSE, [], route: route)
end

#echo(value, route: nil) ⇒ String

Echo the given string.

Parameters:

  • value (String)
  • route (Valkey::Route, nil) (defaults to: nil) —

    cluster routing. When routed, may return a Hash of node => value.

Returns:

  • (String) 


38
39
40
 
# File 'lib/valkey/commands/connection_commands.rb', line 38

def echo(value, route: nil)
  send_command(RequestType::ECHO, [value], route: route)
end

#hello(protover = 3, **options) ⇒ Hash

Switch to a different protocol version and handshake with the server.

Parameters:

  • protover (Integer) (defaults to: 3) —

    Protocol version (2 or 3)

  • options (Hash) —

    Optional parameters like AUTH, SETNAME

Returns:

  • (Hash) —

    Server information (server, version, proto, id, mode, role, modules)



55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/valkey/commands/connection_commands.rb', line 55

def hello(protover = 3, **options)
  args = [protover]

  if options[:auth]
    args << "AUTH"
    args.concat(Array(options[:auth]))
  end

  args << "SETNAME" << options[:setname] if options[:setname]

  send_command(RequestType::HELLO, args)
end

#ping(message = nil, route: nil) ⇒ String

Ping the server.

Examples:

ping             #=> "PONG"
ping("hello")    #=> "hello"
ping(route: Valkey::Route.all_nodes)  #=> Hash (multi-node)

Parameters:

  • message (String, nil) (defaults to: nil) —

    optional message to echo back

  • route (Valkey::Route, nil) (defaults to: nil) —

    cluster routing. When routed, may return a Hash of node => value.

Returns:

  • (String) 


29
30
31
 
# File 'lib/valkey/commands/connection_commands.rb', line 29

def ping(message = nil, route: nil)
  send_command(RequestType::PING, [message].compact, route: route)
end

#reset ⇒ String

Reset the connection state.

Returns:

  • (String) —

    RESET



71
72
73
 
# File 'lib/valkey/commands/connection_commands.rb', line 71

def reset
  send_command(RequestType::RESET)
end

#select(db) ⇒ String

Change the selected database for the current connection.

Parameters:

  • db (Integer) —

    zero-based index of the DB to use (0 to 15)

Returns:

  • (String) —

    OK



46
47
48
 
# File 'lib/valkey/commands/connection_commands.rb', line 46

def select(db)
  send_command(RequestType::SELECT, [db])
end