class Redis::Pipeline
- Redis::Pipeline
- Reference
- Object
Included Modules
Defined in:
pipeline.crConstructors
Instance Method Summary
-
#commit
Read all of the return values from all of the commands we've sent to Redis and resolve all
Redis::Futures with them in the order they were sent. - #run(command)
Instance methods inherited from module Redis::Commands
blpop(*keys : String, timeout : Time::Span)blpop(*keys : String, timeout : Int | Float)
blpop(*keys : String, timeout : String) blpop, brpop(*keys : String, timeout : Time::Span)
brpop(*keys : String, timeout : Int | Float)
brpop(*keys : String, timeout : String) brpop, decr(key : String) decr, decrby(key : String, amount : Int | String) decrby, del(*keys : String) del, exists(*keys : String) exists, get(key : String) get, incr(key : String) incr, incrby(key : String, amount : Int | String) incrby, keys(pattern = "*") keys, lpop(key, *values) lpop, lpush(key, *values) lpush, lrange(key, start, finish) lrange, publish(channel : String, message : String) publish, rpop(key : String) rpop, rpoplpush(source : String, destination : String) rpoplpush, rpush(key, *values) rpush, run(command) run, sadd(key : String, *values : String) sadd, scard(key : String) scard, sdiff(first : String, second : String) sdiff, set(key : String, value : String, ex : String | Int | Nil = nil, px : String | Int | Nil = nil, nx = false, xx = false, keepttl = false)
set(key, value, ex : Time, nx = false, xx = false, keepttl = false)
set(key, value, ex : Time::Span, nx = false, xx = false, keepttl = false) set, sinter(first : String, *others : String) sinter, sismember(key : String, value : String) sismember, smembers(key : String) smembers, srem(key : String, *values : String) srem, xadd(key : String, id : String, maxlen, data : Hash(String, String))
xadd(key : String, id : String, data : Hash(String, String))
xadd(key : String, id : String, maxlen = nil, **data) xadd, xgroup(command : String, key : String, groupname : String)
xgroup(command : String, key : String, groupname : String, *args : String) xgroup, xlen(key : String) xlen, xrange(key : String, start min, end max, count = nil) xrange, xreadgroup(group : String, consumer : String, count : String | Int | Nil = nil, block : Time::Span | String | Int | Nil = nil, no_ack = false, streams : NamedTuple = NamedTuple.new) xreadgroup
Constructor Detail
def self.new(connection : Connection)
#
Instance Method Detail
def commit
#
Read all of the return values from all of the commands we've sent to Redis
and resolve all Redis::Futures with them in the order they were sent.