class

Redis::Connection

Inherits Reference < Object

Constructors

new(socket : TCPSocket)
Source

Instance methods

close
Source
closed?
Source
connected_at
Source
current_db_id
Source
current_db_id=(current_db_id : DatabaseId)
Source
discard_transaction
Source
finish_transaction
Source
flush
Source
has_watched_keys?
Source
in_transaction=(in_transaction : Bool)

Transaction state

Source
in_transaction?

Transaction state

Source
queue_command(commands : Array(RespValue)) : Nil
Source
queued_commands
Source
read_bytes(count : Int32) : Bytes | Nil
Source
read_line
Source
remote_address
Source
send_array(arr : Array(RespValue)) : Nil
Source
send_bulk_string(bytes : Bytes | Nil) : Nil
Source
send_error(message : String | Nil) : Nil
Source
send_integer(num : Int64) : Nil
Source
send_nil
Source
send_ok
Source
send_response(value : RespValue) : Nil
Source
send_simple_string(str : String) : Nil
Source
socket
Source
start_transaction

Transaction management

Source
unwatch_all
Source
watch_key(db_id : DatabaseId, key : Bytes, version : Int64) : Nil

WATCH/UNWATCH management

Source
watched_keys

WATCH state: maps (db_id, key) to version at watch time

Source
write(data : Bytes) : Nil
Source
write_string(str : String) : Nil
Source