Module: Valkey::Commands::PubSubCommands

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

Overview

This module contains commands related to Valkey Pub/Sub. Pub/Sub is not yet supported and is partially implemented. TODO: https://github.com/valkey-io/valkey-glide-ruby/issues/135

See Also:

Instance Method Summary collapse

Instance Method Details

#psubscribe(*patterns) ⇒ String

Subscribe to one or more patterns.

Examples:

Subscribe to patterns

valkey.psubscribe("news.*", "events.*")
  # => "OK"

Parameters:

  • patterns (Array<String>) —

    the patterns to subscribe to

Returns:

  • (String) —

    "OK"

See Also:



53
54
55
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 53

def psubscribe(*patterns)
  send_command(RequestType::PSUBSCRIBE, patterns)
end

#publish(channel, message) ⇒ Integer

Publish a message to a channel.

Examples:

Publish a message

valkey.publish("channel1", "Hello, World!")
  # => 2

Parameters:

  • channel (String) —

    the channel to publish to

  • message (String) —

    the message to publish

Returns:

  • (Integer) —

    the number of clients that received the message

See Also:



85
86
87
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 85

def publish(channel, message)
  send_command(RequestType::PUBLISH, [channel, message])
end

#pubsub(subcommand, *args) ⇒ Object

Control pub/sub operations (convenience method).

Examples:

List active channels

valkey.pubsub(:channels)
  # => ["channel1", "channel2"]

Get pattern count

valkey.pubsub(:numpat)
  # => 3

Get subscriber counts

valkey.pubsub(:numsub, "channel1", "channel2")
  # => ["channel1", 5, "channel2", 3]

List active shard channels

valkey.pubsub(:shardchannels)
  # => ["shard1", "shard2"]

Get shard subscriber counts

valkey.pubsub(:shardnumsub, "shard1", "shard2")
  # => ["shard1", 2, "shard2", 1]

Parameters:

  • subcommand (String, Symbol) —

    the subcommand (channels, numpat, numsub, shardchannels, shardnumsub)

  • args (Array) —

    arguments for the subcommand

Returns:

  • (Object) —

    depends on subcommand



233
234
235
236
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 233

def pubsub(subcommand, *args)
  subcommand = subcommand.to_s.downcase
  send("pubsub_#{subcommand}", *args)
end

#pubsub_channels(pattern = nil) ⇒ Array<String>

List active channels.

Examples:

List all active channels

valkey.pubsub_channels
  # => ["channel1", "channel2"]

List active channels matching a pattern

valkey.pubsub_channels("news.*")
  # => ["news.sports", "news.tech"]

Parameters:

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

    optional pattern to filter channels

Returns:

  • (Array<String>) —

    list of active channels

See Also:



148
149
150
151
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 148

def pubsub_channels(pattern = nil)
  args = pattern ? [pattern] : []
  send_command(RequestType::PUBSUB_CHANNELS, args)
end

#pubsub_numpat ⇒ Integer

Get the number of unique patterns subscribed to.

Examples:

Get pattern count

valkey.pubsub_numpat
  # => 3

Returns:

  • (Integer) —

    the number of patterns

See Also:



162
163
164
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 162

def pubsub_numpat
  send_command(RequestType::PUBSUB_NUM_PAT)
end

#pubsub_numsub(*channels) ⇒ Hash

Get the number of subscribers for channels.

Examples:

Get subscriber counts

valkey.pubsub_numsub("channel1", "channel2")
  # => ["channel1", 5, "channel2", 3]

Parameters:

  • channels (Array<String>) —

    the channels to check

Returns:

  • (Hash) —

    channel names mapped to subscriber counts

See Also:



176
177
178
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 176

def pubsub_numsub(*channels)
  send_command(RequestType::PUBSUB_NUM_SUB, channels)
end

#pubsub_shardchannels(pattern = nil) ⇒ Array<String>

List active shard channels.

Examples:

List all active shard channels

valkey.pubsub_shardchannels
  # => ["shard1", "shard2"]

List active shard channels matching a pattern

valkey.pubsub_shardchannels("shard.*")
  # => ["shard.1", "shard.2"]

Parameters:

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

    optional pattern to filter shard channels

Returns:

  • (Array<String>) —

    list of active shard channels

See Also:



193
194
195
196
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 193

def pubsub_shardchannels(pattern = nil)
  args = pattern ? [pattern] : []
  send_command(RequestType::PUBSUB_SHARD_CHANNELS, args)
end

#pubsub_shardnumsub(*channels) ⇒ Hash

Get the number of subscribers for shard channels.

Examples:

Get shard subscriber counts

valkey.pubsub_shardnumsub("shard1", "shard2")
  # => ["shard1", 2, "shard2", 1]

Parameters:

  • channels (Array<String>) —

    the shard channels to check

Returns:

  • (Hash) —

    shard channel names mapped to subscriber counts

See Also:



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

def pubsub_shardnumsub(*channels)
  send_command(RequestType::PUBSUB_SHARD_NUM_SUB, channels)
end

#punsubscribe(*patterns) ⇒ String

Unsubscribe from one or more patterns.

Examples:

Unsubscribe from patterns

valkey.punsubscribe("news.*", "events.*")
  # => "OK"

Unsubscribe from all patterns

valkey.punsubscribe
  # => "OK"

Parameters:

  • patterns (Array<String>) —

    the patterns to unsubscribe from (empty for all)

Returns:

  • (String) —

    "OK"

See Also:



70
71
72
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 70

def punsubscribe(*patterns)
  send_command(RequestType::PUNSUBSCRIBE, patterns)
end

#spublish(channel, message) ⇒ Integer

Publish a message to a shard channel.

Examples:

Publish a message to a shard channel

valkey.spublish("shard1", "Hello, Shard!")
  # => 1

Parameters:

  • channel (String) —

    the shard channel to publish to

  • message (String) —

    the message to publish

Returns:

  • (Integer) —

    the number of clients that received the message

See Also:



131
132
133
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 131

def spublish(channel, message)
  send_command(RequestType::SPUBLISH, [channel, message])
end

#ssubscribe(*channels) ⇒ String

Subscribe to one or more shard channels.

Examples:

Subscribe to shard channels

valkey.ssubscribe("shard1", "shard2")
  # => "OK"

Parameters:

  • channels (Array<String>) —

    the shard channels to subscribe to

Returns:

  • (String) —

    "OK"

See Also:



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

def ssubscribe(*channels)
  send_command(RequestType::SSUBSCRIBE, channels)
end

#subscribe(*channels) ⇒ String

Subscribe to one or more channels.

Examples:

Subscribe to channels

valkey.subscribe("channel1", "channel2")
  # => "OK"

Parameters:

  • channels (Array<String>) —

    the channels to subscribe to

Returns:

  • (String) —

    "OK"

See Also:



22
23
24
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 22

def subscribe(*channels)
  send_command(RequestType::SUBSCRIBE, channels)
end

#sunsubscribe(*channels) ⇒ String

Unsubscribe from one or more shard channels.

Examples:

Unsubscribe from shard channels

valkey.sunsubscribe("shard1", "shard2")
  # => "OK"

Unsubscribe from all shard channels

valkey.sunsubscribe
  # => "OK"

Parameters:

  • channels (Array<String>) —

    the shard channels to unsubscribe from (empty for all)

Returns:

  • (String) —

    "OK"

See Also:



116
117
118
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 116

def sunsubscribe(*channels)
  send_command(RequestType::SUNSUBSCRIBE, channels)
end

#unsubscribe(*channels) ⇒ String

Unsubscribe from one or more channels.

Examples:

Unsubscribe from channels

valkey.unsubscribe("channel1", "channel2")
  # => "OK"

Unsubscribe from all channels

valkey.unsubscribe
  # => "OK"

Parameters:

  • channels (Array<String>) —

    the channels to unsubscribe from (empty for all)

Returns:

  • (String) —

    "OK"

See Also:



39
40
41
 
# File 'lib/valkey/commands/pubsub_commands.rb', line 39

def unsubscribe(*channels)
  send_command(RequestType::UNSUBSCRIBE, channels)
end