class Redis::Connection

• Redis::Connection
• Reference
• Object

Overview

The connection wraps the TCP connection to the Redis server.

Included Modules

• Redis::Commands

Defined in:

Constructors

• .new(uri : URI = URI.parse("redis:///"))

  We receive all connection information in the URI.

Instance Method Summary

• #close

  Close the connection to the server.

• #encode(command)
• #flush

  Flush the connection buffer and make sure we've sent everything to the server.

• #multi(retries = 5, &)

  Execute a transaction within the server.

• #pipeline(&)

  Execute a pipeline of commands.

• #psubscribe(*channels : String, &block : Subscription, self -> )
• #punsubscribe(*channels : String)
• #read

  Read the next value from the server

• #readonly! : Nil
• #run(command, retries = 5) : Value

  Execute the given command and return the result from the server.

• #scan_each(match pattern : String | Nil = nil, count : String | Int | Nil = nil, type : String | Nil = nil, &) : Nil
• #subscribe(*channels : String, &block : Subscription, self -> )
• #subscribe(*channels : String)
• #unsubscribe(*channels : String)
• #url

Constructor Detail

Instance Method Detail

redis.multi do |redis|
  redis.set "foo", "bar"
  redis.incr "counter"
  raise "Oops!"
end

redis.get "foo"     # => nil
redis.get "counter" # => nil

redis.pipeline do |redis|
  redis.set "foo", "bar"
  redis.incr "counter"
end

run({"set", "foo", "bar"})