Documentation ¶
Overview ¶
This package implements an asynchronous Redis client.
Client is a structure for accessing a Redis database. Client.MultiCall can be used for sending multiple commands in a single request and Client.Transaction offers a simple way for executing atomic requests. Client.Subscription returns a Subscription that can be used for listening published messages.
Index ¶
- type Client
- func (c *Client) Append(args ...interface{}) *Reply
- func (c *Client) Asking(args ...interface{}) *Reply
- func (c *Client) AsyncAppend(args ...interface{}) Future
- func (c *Client) AsyncAsking(args ...interface{}) Future
- func (c *Client) AsyncAuth(args ...interface{}) Future
- func (c *Client) AsyncBgrewriteaof(args ...interface{}) Future
- func (c *Client) AsyncBgsave(args ...interface{}) Future
- func (c *Client) AsyncBitcount(args ...interface{}) Future
- func (c *Client) AsyncBitop(args ...interface{}) Future
- func (c *Client) AsyncBlpop(args ...interface{}) Future
- func (c *Client) AsyncBrpop(args ...interface{}) Future
- func (c *Client) AsyncBrpoplpush(args ...interface{}) Future
- func (c *Client) AsyncCall(cmd string, args ...interface{}) Future
- func (c *Client) AsyncClient(args ...interface{}) Future
- func (c *Client) AsyncCluster(args ...interface{}) Future
- func (c *Client) AsyncConfig(args ...interface{}) Future
- func (c *Client) AsyncDbsize(args ...interface{}) Future
- func (c *Client) AsyncDebug(args ...interface{}) Future
- func (c *Client) AsyncDecr(args ...interface{}) Future
- func (c *Client) AsyncDecrby(args ...interface{}) Future
- func (c *Client) AsyncDel(args ...interface{}) Future
- func (c *Client) AsyncDiscard(args ...interface{}) Future
- func (c *Client) AsyncDump(args ...interface{}) Future
- func (c *Client) AsyncEcho(args ...interface{}) Future
- func (c *Client) AsyncEval(args ...interface{}) Future
- func (c *Client) AsyncExec(args ...interface{}) Future
- func (c *Client) AsyncExists(args ...interface{}) Future
- func (c *Client) AsyncExpire(args ...interface{}) Future
- func (c *Client) AsyncExpireat(args ...interface{}) Future
- func (c *Client) AsyncFlushall(args ...interface{}) Future
- func (c *Client) AsyncFlushdb(args ...interface{}) Future
- func (c *Client) AsyncGet(args ...interface{}) Future
- func (c *Client) AsyncGetbit(args ...interface{}) Future
- func (c *Client) AsyncGetrange(args ...interface{}) Future
- func (c *Client) AsyncGetset(args ...interface{}) Future
- func (c *Client) AsyncHdel(args ...interface{}) Future
- func (c *Client) AsyncHexists(args ...interface{}) Future
- func (c *Client) AsyncHget(args ...interface{}) Future
- func (c *Client) AsyncHgetall(args ...interface{}) Future
- func (c *Client) AsyncHincrby(args ...interface{}) Future
- func (c *Client) AsyncHincrbyfloat(args ...interface{}) Future
- func (c *Client) AsyncHkeys(args ...interface{}) Future
- func (c *Client) AsyncHlen(args ...interface{}) Future
- func (c *Client) AsyncHmget(args ...interface{}) Future
- func (c *Client) AsyncHmset(args ...interface{}) Future
- func (c *Client) AsyncHset(args ...interface{}) Future
- func (c *Client) AsyncHsetnx(args ...interface{}) Future
- func (c *Client) AsyncHvals(args ...interface{}) Future
- func (c *Client) AsyncIncr(args ...interface{}) Future
- func (c *Client) AsyncIncrby(args ...interface{}) Future
- func (c *Client) AsyncIncrbyfloat(args ...interface{}) Future
- func (c *Client) AsyncInfo(args ...interface{}) Future
- func (c *Client) AsyncKeys(args ...interface{}) Future
- func (c *Client) AsyncLastsave(args ...interface{}) Future
- func (c *Client) AsyncLindex(args ...interface{}) Future
- func (c *Client) AsyncLinsert(args ...interface{}) Future
- func (c *Client) AsyncLlen(args ...interface{}) Future
- func (c *Client) AsyncLpop(args ...interface{}) Future
- func (c *Client) AsyncLpush(args ...interface{}) Future
- func (c *Client) AsyncLpushx(args ...interface{}) Future
- func (c *Client) AsyncLrange(args ...interface{}) Future
- func (c *Client) AsyncLrem(args ...interface{}) Future
- func (c *Client) AsyncLset(args ...interface{}) Future
- func (c *Client) AsyncLtrim(args ...interface{}) Future
- func (c *Client) AsyncMget(args ...interface{}) Future
- func (c *Client) AsyncMigrate(args ...interface{}) Future
- func (c *Client) AsyncMonitor(args ...interface{}) Future
- func (c *Client) AsyncMove(args ...interface{}) Future
- func (c *Client) AsyncMset(args ...interface{}) Future
- func (c *Client) AsyncMsetnx(args ...interface{}) Future
- func (c *Client) AsyncMulti(args ...interface{}) Future
- func (c *Client) AsyncMultiCall(mc func(*MultiCall)) Future
- func (c *Client) AsyncObject(args ...interface{}) Future
- func (c *Client) AsyncPersist(args ...interface{}) Future
- func (c *Client) AsyncPexpire(args ...interface{}) Future
- func (c *Client) AsyncPexpireat(args ...interface{}) Future
- func (c *Client) AsyncPing(args ...interface{}) Future
- func (c *Client) AsyncPsetex(args ...interface{}) Future
- func (c *Client) AsyncPsubscribe(args ...interface{}) Future
- func (c *Client) AsyncPttl(args ...interface{}) Future
- func (c *Client) AsyncPublish(args ...interface{}) Future
- func (c *Client) AsyncPunsubscribe(args ...interface{}) Future
- func (c *Client) AsyncRandomkey(args ...interface{}) Future
- func (c *Client) AsyncRename(args ...interface{}) Future
- func (c *Client) AsyncRenamenx(args ...interface{}) Future
- func (c *Client) AsyncReplconf(args ...interface{}) Future
- func (c *Client) AsyncRestore(args ...interface{}) Future
- func (c *Client) AsyncRpop(args ...interface{}) Future
- func (c *Client) AsyncRpoplpush(args ...interface{}) Future
- func (c *Client) AsyncRpush(args ...interface{}) Future
- func (c *Client) AsyncRpushx(args ...interface{}) Future
- func (c *Client) AsyncSadd(args ...interface{}) Future
- func (c *Client) AsyncSave(args ...interface{}) Future
- func (c *Client) AsyncScard(args ...interface{}) Future
- func (c *Client) AsyncScript(args ...interface{}) Future
- func (c *Client) AsyncSdiff(args ...interface{}) Future
- func (c *Client) AsyncSdiffstore(args ...interface{}) Future
- func (c *Client) AsyncSelect(args ...interface{}) Future
- func (c *Client) AsyncSet(args ...interface{}) Future
- func (c *Client) AsyncSetbit(args ...interface{}) Future
- func (c *Client) AsyncSetex(args ...interface{}) Future
- func (c *Client) AsyncSetnx(args ...interface{}) Future
- func (c *Client) AsyncSetrange(args ...interface{}) Future
- func (c *Client) AsyncShutdown(args ...interface{}) Future
- func (c *Client) AsyncSinter(args ...interface{}) Future
- func (c *Client) AsyncSinterstore(args ...interface{}) Future
- func (c *Client) AsyncSismember(args ...interface{}) Future
- func (c *Client) AsyncSlaveof(args ...interface{}) Future
- func (c *Client) AsyncSmembers(args ...interface{}) Future
- func (c *Client) AsyncSmove(args ...interface{}) Future
- func (c *Client) AsyncSort(args ...interface{}) Future
- func (c *Client) AsyncSpop(args ...interface{}) Future
- func (c *Client) AsyncSrandmember(args ...interface{}) Future
- func (c *Client) AsyncSrem(args ...interface{}) Future
- func (c *Client) AsyncStrlen(args ...interface{}) Future
- func (c *Client) AsyncSubscribe(args ...interface{}) Future
- func (c *Client) AsyncSunion(args ...interface{}) Future
- func (c *Client) AsyncSunionstore(args ...interface{}) Future
- func (c *Client) AsyncSync(args ...interface{}) Future
- func (c *Client) AsyncTime(args ...interface{}) Future
- func (c *Client) AsyncTransaction(mc func(*MultiCall)) Future
- func (c *Client) AsyncTtl(args ...interface{}) Future
- func (c *Client) AsyncType(args ...interface{}) Future
- func (c *Client) AsyncUnsubscribe(args ...interface{}) Future
- func (c *Client) AsyncUnwatch(args ...interface{}) Future
- func (c *Client) AsyncWatch(args ...interface{}) Future
- func (c *Client) AsyncZadd(args ...interface{}) Future
- func (c *Client) AsyncZcard(args ...interface{}) Future
- func (c *Client) AsyncZcount(args ...interface{}) Future
- func (c *Client) AsyncZincrby(args ...interface{}) Future
- func (c *Client) AsyncZinterstore(args ...interface{}) Future
- func (c *Client) AsyncZrange(args ...interface{}) Future
- func (c *Client) AsyncZrangebyscore(args ...interface{}) Future
- func (c *Client) AsyncZrank(args ...interface{}) Future
- func (c *Client) AsyncZrem(args ...interface{}) Future
- func (c *Client) AsyncZremrangebyrank(args ...interface{}) Future
- func (c *Client) AsyncZremrangebyscore(args ...interface{}) Future
- func (c *Client) AsyncZrevrange(args ...interface{}) Future
- func (c *Client) AsyncZrevrangebyscore(args ...interface{}) Future
- func (c *Client) AsyncZrevrank(args ...interface{}) Future
- func (c *Client) AsyncZscore(args ...interface{}) Future
- func (c *Client) AsyncZunionstore(args ...interface{}) Future
- func (c *Client) Auth(args ...interface{}) *Reply
- func (c *Client) Bgrewriteaof(args ...interface{}) *Reply
- func (c *Client) Bgsave(args ...interface{}) *Reply
- func (c *Client) Bitcount(args ...interface{}) *Reply
- func (c *Client) Bitop(args ...interface{}) *Reply
- func (c *Client) Blpop(args ...interface{}) *Reply
- func (c *Client) Brpop(args ...interface{}) *Reply
- func (c *Client) Brpoplpush(args ...interface{}) *Reply
- func (c *Client) Call(cmd string, args ...interface{}) *Reply
- func (c *Client) Client(args ...interface{}) *Reply
- func (c *Client) Close()
- func (c *Client) Cluster(args ...interface{}) *Reply
- func (c *Client) Config(args ...interface{}) *Reply
- func (c *Client) Dbsize(args ...interface{}) *Reply
- func (c *Client) Debug(args ...interface{}) *Reply
- func (c *Client) Decr(args ...interface{}) *Reply
- func (c *Client) Decrby(args ...interface{}) *Reply
- func (c *Client) Del(args ...interface{}) *Reply
- func (c *Client) Discard(args ...interface{}) *Reply
- func (c *Client) Dump(args ...interface{}) *Reply
- func (c *Client) Echo(args ...interface{}) *Reply
- func (c *Client) Eval(args ...interface{}) *Reply
- func (c *Client) Exec(args ...interface{}) *Reply
- func (c *Client) Exists(args ...interface{}) *Reply
- func (c *Client) Expire(args ...interface{}) *Reply
- func (c *Client) Expireat(args ...interface{}) *Reply
- func (c *Client) Flushall(args ...interface{}) *Reply
- func (c *Client) Flushdb(args ...interface{}) *Reply
- func (c *Client) Get(args ...interface{}) *Reply
- func (c *Client) Getbit(args ...interface{}) *Reply
- func (c *Client) Getrange(args ...interface{}) *Reply
- func (c *Client) Getset(args ...interface{}) *Reply
- func (c *Client) Hdel(args ...interface{}) *Reply
- func (c *Client) Hexists(args ...interface{}) *Reply
- func (c *Client) Hget(args ...interface{}) *Reply
- func (c *Client) Hgetall(args ...interface{}) *Reply
- func (c *Client) Hincrby(args ...interface{}) *Reply
- func (c *Client) Hincrbyfloat(args ...interface{}) *Reply
- func (c *Client) Hkeys(args ...interface{}) *Reply
- func (c *Client) Hlen(args ...interface{}) *Reply
- func (c *Client) Hmget(args ...interface{}) *Reply
- func (c *Client) Hmset(args ...interface{}) *Reply
- func (c *Client) Hset(args ...interface{}) *Reply
- func (c *Client) Hsetnx(args ...interface{}) *Reply
- func (c *Client) Hvals(args ...interface{}) *Reply
- func (c *Client) Incr(args ...interface{}) *Reply
- func (c *Client) Incrby(args ...interface{}) *Reply
- func (c *Client) Incrbyfloat(args ...interface{}) *Reply
- func (c *Client) Info(args ...interface{}) *Reply
- func (c *Client) InfoMap() (map[string]string, error)
- func (c *Client) Keys(args ...interface{}) *Reply
- func (c *Client) Lastsave(args ...interface{}) *Reply
- func (c *Client) Lindex(args ...interface{}) *Reply
- func (c *Client) Linsert(args ...interface{}) *Reply
- func (c *Client) Llen(args ...interface{}) *Reply
- func (c *Client) Lpop(args ...interface{}) *Reply
- func (c *Client) Lpush(args ...interface{}) *Reply
- func (c *Client) Lpushx(args ...interface{}) *Reply
- func (c *Client) Lrange(args ...interface{}) *Reply
- func (c *Client) Lrem(args ...interface{}) *Reply
- func (c *Client) Lset(args ...interface{}) *Reply
- func (c *Client) Ltrim(args ...interface{}) *Reply
- func (c *Client) Mget(args ...interface{}) *Reply
- func (c *Client) Migrate(args ...interface{}) *Reply
- func (c *Client) Monitor(args ...interface{}) *Reply
- func (c *Client) Move(args ...interface{}) *Reply
- func (c *Client) Mset(args ...interface{}) *Reply
- func (c *Client) Msetnx(args ...interface{}) *Reply
- func (c *Client) Multi(args ...interface{}) *Reply
- func (c *Client) MultiCall(f func(*MultiCall)) *Reply
- func (c *Client) Object(args ...interface{}) *Reply
- func (c *Client) Persist(args ...interface{}) *Reply
- func (c *Client) Pexpire(args ...interface{}) *Reply
- func (c *Client) Pexpireat(args ...interface{}) *Reply
- func (c *Client) Ping(args ...interface{}) *Reply
- func (c *Client) Psetex(args ...interface{}) *Reply
- func (c *Client) Psubscribe(args ...interface{}) *Reply
- func (c *Client) Pttl(args ...interface{}) *Reply
- func (c *Client) Publish(args ...interface{}) *Reply
- func (c *Client) Punsubscribe(args ...interface{}) *Reply
- func (c *Client) Randomkey(args ...interface{}) *Reply
- func (c *Client) Rename(args ...interface{}) *Reply
- func (c *Client) Renamenx(args ...interface{}) *Reply
- func (c *Client) Replconf(args ...interface{}) *Reply
- func (c *Client) Restore(args ...interface{}) *Reply
- func (c *Client) Rpop(args ...interface{}) *Reply
- func (c *Client) Rpoplpush(args ...interface{}) *Reply
- func (c *Client) Rpush(args ...interface{}) *Reply
- func (c *Client) Rpushx(args ...interface{}) *Reply
- func (c *Client) Sadd(args ...interface{}) *Reply
- func (c *Client) Save(args ...interface{}) *Reply
- func (c *Client) Scard(args ...interface{}) *Reply
- func (c *Client) Script(args ...interface{}) *Reply
- func (c *Client) Sdiff(args ...interface{}) *Reply
- func (c *Client) Sdiffstore(args ...interface{}) *Reply
- func (c *Client) Select(args ...interface{}) *Reply
- func (c *Client) Set(args ...interface{}) *Reply
- func (c *Client) Setbit(args ...interface{}) *Reply
- func (c *Client) Setex(args ...interface{}) *Reply
- func (c *Client) Setnx(args ...interface{}) *Reply
- func (c *Client) Setrange(args ...interface{}) *Reply
- func (c *Client) Shutdown(args ...interface{}) *Reply
- func (c *Client) Sinter(args ...interface{}) *Reply
- func (c *Client) Sinterstore(args ...interface{}) *Reply
- func (c *Client) Sismember(args ...interface{}) *Reply
- func (c *Client) Slaveof(args ...interface{}) *Reply
- func (c *Client) Smembers(args ...interface{}) *Reply
- func (c *Client) Smove(args ...interface{}) *Reply
- func (c *Client) Sort(args ...interface{}) *Reply
- func (c *Client) Spop(args ...interface{}) *Reply
- func (c *Client) Srandmember(args ...interface{}) *Reply
- func (c *Client) Srem(args ...interface{}) *Reply
- func (c *Client) Strlen(args ...interface{}) *Reply
- func (c *Client) Subscribe(args ...interface{}) *Reply
- func (c *Client) Subscription(msgHdlr func(msg *Message)) (*Subscription, *Error)
- func (c *Client) Sunion(args ...interface{}) *Reply
- func (c *Client) Sunionstore(args ...interface{}) *Reply
- func (c *Client) Sync(args ...interface{}) *Reply
- func (c *Client) Time(args ...interface{}) *Reply
- func (c *Client) Transaction(f func(*MultiCall)) *Reply
- func (c *Client) Ttl(args ...interface{}) *Reply
- func (c *Client) Type(args ...interface{}) *Reply
- func (c *Client) Unsubscribe(args ...interface{}) *Reply
- func (c *Client) Unwatch(args ...interface{}) *Reply
- func (c *Client) Watch(args ...interface{}) *Reply
- func (c *Client) Zadd(args ...interface{}) *Reply
- func (c *Client) Zcard(args ...interface{}) *Reply
- func (c *Client) Zcount(args ...interface{}) *Reply
- func (c *Client) Zincrby(args ...interface{}) *Reply
- func (c *Client) Zinterstore(args ...interface{}) *Reply
- func (c *Client) Zrange(args ...interface{}) *Reply
- func (c *Client) Zrangebyscore(args ...interface{}) *Reply
- func (c *Client) Zrank(args ...interface{}) *Reply
- func (c *Client) Zrem(args ...interface{}) *Reply
- func (c *Client) Zremrangebyrank(args ...interface{}) *Reply
- func (c *Client) Zremrangebyscore(args ...interface{}) *Reply
- func (c *Client) Zrevrange(args ...interface{}) *Reply
- func (c *Client) Zrevrangebyscore(args ...interface{}) *Reply
- func (c *Client) Zrevrank(args ...interface{}) *Reply
- func (c *Client) Zscore(args ...interface{}) *Reply
- func (c *Client) Zunionstore(args ...interface{}) *Reply
- type Cmd
- type Config
- type Error
- type ErrorFlag
- type Future
- type Message
- type MessageType
- type MultiCall
- func (mc *MultiCall) Append(args ...interface{})
- func (mc *MultiCall) Asking(args ...interface{})
- func (mc *MultiCall) Auth(args ...interface{})
- func (mc *MultiCall) Bgrewriteaof(args ...interface{})
- func (mc *MultiCall) Bgsave(args ...interface{})
- func (mc *MultiCall) Bitcount(args ...interface{})
- func (mc *MultiCall) Bitop(args ...interface{})
- func (mc *MultiCall) Blpop(args ...interface{})
- func (mc *MultiCall) Brpop(args ...interface{})
- func (mc *MultiCall) Brpoplpush(args ...interface{})
- func (mc *MultiCall) Call(cmd string, args ...interface{})
- func (mc *MultiCall) Client(args ...interface{})
- func (mc *MultiCall) Cluster(args ...interface{})
- func (mc *MultiCall) Config(args ...interface{})
- func (mc *MultiCall) Dbsize(args ...interface{})
- func (mc *MultiCall) Debug(args ...interface{})
- func (mc *MultiCall) Decr(args ...interface{})
- func (mc *MultiCall) Decrby(args ...interface{})
- func (mc *MultiCall) Del(args ...interface{})
- func (mc *MultiCall) Discard(args ...interface{})
- func (mc *MultiCall) Dump(args ...interface{})
- func (mc *MultiCall) Echo(args ...interface{})
- func (mc *MultiCall) Eval(args ...interface{})
- func (mc *MultiCall) Exec(args ...interface{})
- func (mc *MultiCall) Exists(args ...interface{})
- func (mc *MultiCall) Expire(args ...interface{})
- func (mc *MultiCall) Expireat(args ...interface{})
- func (mc *MultiCall) Flush() (r *Reply)
- func (mc *MultiCall) Flushall(args ...interface{})
- func (mc *MultiCall) Flushdb(args ...interface{})
- func (mc *MultiCall) Get(args ...interface{})
- func (mc *MultiCall) Getbit(args ...interface{})
- func (mc *MultiCall) Getrange(args ...interface{})
- func (mc *MultiCall) Getset(args ...interface{})
- func (mc *MultiCall) Hdel(args ...interface{})
- func (mc *MultiCall) Hexists(args ...interface{})
- func (mc *MultiCall) Hget(args ...interface{})
- func (mc *MultiCall) Hgetall(args ...interface{})
- func (mc *MultiCall) Hincrby(args ...interface{})
- func (mc *MultiCall) Hincrbyfloat(args ...interface{})
- func (mc *MultiCall) Hkeys(args ...interface{})
- func (mc *MultiCall) Hlen(args ...interface{})
- func (mc *MultiCall) Hmget(args ...interface{})
- func (mc *MultiCall) Hmset(args ...interface{})
- func (mc *MultiCall) Hset(args ...interface{})
- func (mc *MultiCall) Hsetnx(args ...interface{})
- func (mc *MultiCall) Hvals(args ...interface{})
- func (mc *MultiCall) Incr(args ...interface{})
- func (mc *MultiCall) Incrby(args ...interface{})
- func (mc *MultiCall) Incrbyfloat(args ...interface{})
- func (mc *MultiCall) Info(args ...interface{})
- func (mc *MultiCall) Keys(args ...interface{})
- func (mc *MultiCall) Lastsave(args ...interface{})
- func (mc *MultiCall) Lindex(args ...interface{})
- func (mc *MultiCall) Linsert(args ...interface{})
- func (mc *MultiCall) Llen(args ...interface{})
- func (mc *MultiCall) Lpop(args ...interface{})
- func (mc *MultiCall) Lpush(args ...interface{})
- func (mc *MultiCall) Lpushx(args ...interface{})
- func (mc *MultiCall) Lrange(args ...interface{})
- func (mc *MultiCall) Lrem(args ...interface{})
- func (mc *MultiCall) Lset(args ...interface{})
- func (mc *MultiCall) Ltrim(args ...interface{})
- func (mc *MultiCall) Mget(args ...interface{})
- func (mc *MultiCall) Migrate(args ...interface{})
- func (mc *MultiCall) Monitor(args ...interface{})
- func (mc *MultiCall) Move(args ...interface{})
- func (mc *MultiCall) Mset(args ...interface{})
- func (mc *MultiCall) Msetnx(args ...interface{})
- func (mc *MultiCall) Multi(args ...interface{})
- func (mc *MultiCall) Object(args ...interface{})
- func (mc *MultiCall) Persist(args ...interface{})
- func (mc *MultiCall) Pexpire(args ...interface{})
- func (mc *MultiCall) Pexpireat(args ...interface{})
- func (mc *MultiCall) Ping(args ...interface{})
- func (mc *MultiCall) Psetex(args ...interface{})
- func (mc *MultiCall) Psubscribe(args ...interface{})
- func (mc *MultiCall) Pttl(args ...interface{})
- func (mc *MultiCall) Publish(args ...interface{})
- func (mc *MultiCall) Punsubscribe(args ...interface{})
- func (mc *MultiCall) Randomkey(args ...interface{})
- func (mc *MultiCall) Rename(args ...interface{})
- func (mc *MultiCall) Renamenx(args ...interface{})
- func (mc *MultiCall) Replconf(args ...interface{})
- func (mc *MultiCall) Restore(args ...interface{})
- func (mc *MultiCall) Rpop(args ...interface{})
- func (mc *MultiCall) Rpoplpush(args ...interface{})
- func (mc *MultiCall) Rpush(args ...interface{})
- func (mc *MultiCall) Rpushx(args ...interface{})
- func (mc *MultiCall) Sadd(args ...interface{})
- func (mc *MultiCall) Save(args ...interface{})
- func (mc *MultiCall) Scard(args ...interface{})
- func (mc *MultiCall) Script(args ...interface{})
- func (mc *MultiCall) Sdiff(args ...interface{})
- func (mc *MultiCall) Sdiffstore(args ...interface{})
- func (mc *MultiCall) Select(args ...interface{})
- func (mc *MultiCall) Set(args ...interface{})
- func (mc *MultiCall) Setbit(args ...interface{})
- func (mc *MultiCall) Setex(args ...interface{})
- func (mc *MultiCall) Setnx(args ...interface{})
- func (mc *MultiCall) Setrange(args ...interface{})
- func (mc *MultiCall) Shutdown(args ...interface{})
- func (mc *MultiCall) Sinter(args ...interface{})
- func (mc *MultiCall) Sinterstore(args ...interface{})
- func (mc *MultiCall) Sismember(args ...interface{})
- func (mc *MultiCall) Slaveof(args ...interface{})
- func (mc *MultiCall) Smembers(args ...interface{})
- func (mc *MultiCall) Smove(args ...interface{})
- func (mc *MultiCall) Sort(args ...interface{})
- func (mc *MultiCall) Spop(args ...interface{})
- func (mc *MultiCall) Srandmember(args ...interface{})
- func (mc *MultiCall) Srem(args ...interface{})
- func (mc *MultiCall) Strlen(args ...interface{})
- func (mc *MultiCall) Subscribe(args ...interface{})
- func (mc *MultiCall) Sunion(args ...interface{})
- func (mc *MultiCall) Sunionstore(args ...interface{})
- func (mc *MultiCall) Sync(args ...interface{})
- func (mc *MultiCall) Time(args ...interface{})
- func (mc *MultiCall) Ttl(args ...interface{})
- func (mc *MultiCall) Type(args ...interface{})
- func (mc *MultiCall) Unsubscribe(args ...interface{})
- func (mc *MultiCall) Unwatch(args ...interface{})
- func (mc *MultiCall) Watch(args ...interface{})
- func (mc *MultiCall) Zadd(args ...interface{})
- func (mc *MultiCall) Zcard(args ...interface{})
- func (mc *MultiCall) Zcount(args ...interface{})
- func (mc *MultiCall) Zincrby(args ...interface{})
- func (mc *MultiCall) Zinterstore(args ...interface{})
- func (mc *MultiCall) Zrange(args ...interface{})
- func (mc *MultiCall) Zrangebyscore(args ...interface{})
- func (mc *MultiCall) Zrank(args ...interface{})
- func (mc *MultiCall) Zrem(args ...interface{})
- func (mc *MultiCall) Zremrangebyrank(args ...interface{})
- func (mc *MultiCall) Zremrangebyscore(args ...interface{})
- func (mc *MultiCall) Zrevrange(args ...interface{})
- func (mc *MultiCall) Zrevrangebyscore(args ...interface{})
- func (mc *MultiCall) Zrevrank(args ...interface{})
- func (mc *MultiCall) Zscore(args ...interface{})
- func (mc *MultiCall) Zunionstore(args ...interface{})
- type Reply
- func (r *Reply) Bool() (bool, error)
- func (r *Reply) Bytes() ([]byte, error)
- func (r *Reply) Hash() (map[string]string, error)
- func (r *Reply) Int() (int, error)
- func (r *Reply) Int64() (int64, error)
- func (r *Reply) List() ([]string, error)
- func (r *Reply) Str() (string, error)
- func (r *Reply) String() string
- type ReplyType
- type Subscription
- func (s *Subscription) Close()
- func (s *Subscription) Psubscribe(patterns ...string) (err *Error)
- func (s *Subscription) Punsubscribe(patterns ...string) (err *Error)
- func (s *Subscription) Subscribe(channels ...string) (err *Error)
- func (s *Subscription) Unsubscribe(channels ...string) (err *Error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client manages the access to a database.
func (*Client) AsyncAppend ¶ added in v0.2.0
AsyncAppend calls Redis APPEND asynchronously.
func (*Client) AsyncAsking ¶ added in v0.2.0
AsyncAsking calls Redis ASKING asynchronously.
func (*Client) AsyncBgrewriteaof ¶ added in v0.2.0
AsyncBgrewriteaof calls Redis BGREWRITEAOF asynchronously.
func (*Client) AsyncBgsave ¶ added in v0.2.0
AsyncBgsave calls Redis BGSAVE asynchronously.
func (*Client) AsyncBitcount ¶ added in v0.3.0
AsyncBitcount calls Redis BITCOUNT asynchronously.
func (*Client) AsyncBitop ¶ added in v0.3.0
AsyncBitop calls Redis BITOP asynchronously.
func (*Client) AsyncBlpop ¶ added in v0.2.0
AsyncBlpop calls Redis BLPOP asynchronously.
func (*Client) AsyncBrpop ¶ added in v0.2.0
AsyncBrpop calls Redis BRPOP asynchronously.
func (*Client) AsyncBrpoplpush ¶ added in v0.2.0
AsyncBrpoplpush calls Redis BRPOPLPUSH asynchronously.
func (*Client) AsyncClient ¶ added in v0.2.0
AsyncClient calls Redis CLIENT asynchronously.
func (*Client) AsyncCluster ¶ added in v0.2.0
AsyncCluster calls Redis CLUSTER asynchronously.
func (*Client) AsyncConfig ¶ added in v0.2.0
AsyncConfig calls Redis CONFIG asynchronously.
func (*Client) AsyncDbsize ¶ added in v0.2.0
AsyncDbsize calls Redis DBSIZE asynchronously.
func (*Client) AsyncDebug ¶ added in v0.2.0
AsyncDebug calls Redis DEBUG asynchronously.
func (*Client) AsyncDecrby ¶ added in v0.2.0
AsyncDecrby calls Redis DECRBY asynchronously.
func (*Client) AsyncDiscard ¶ added in v0.2.0
AsyncDiscard calls Redis DISCARD asynchronously.
func (*Client) AsyncExists ¶ added in v0.2.0
AsyncExists calls Redis EXISTS asynchronously.
func (*Client) AsyncExpire ¶ added in v0.2.0
AsyncExpire calls Redis EXPIRE asynchronously.
func (*Client) AsyncExpireat ¶ added in v0.2.0
AsyncExpireat calls Redis EXPIREAT asynchronously.
func (*Client) AsyncFlushall ¶ added in v0.2.0
AsyncFlushall calls Redis FLUSHALL asynchronously.
func (*Client) AsyncFlushdb ¶ added in v0.2.0
AsyncFlushdb calls Redis FLUSHDB asynchronously.
func (*Client) AsyncGetbit ¶ added in v0.2.0
AsyncGetbit calls Redis GETBIT asynchronously.
func (*Client) AsyncGetrange ¶ added in v0.2.0
AsyncGetrange calls Redis GETRANGE asynchronously.
func (*Client) AsyncGetset ¶ added in v0.2.0
AsyncGetset calls Redis GETSET asynchronously.
func (*Client) AsyncHexists ¶ added in v0.2.0
AsyncHexists calls Redis HEXISTS asynchronously.
func (*Client) AsyncHgetall ¶ added in v0.2.0
AsyncHgetall calls Redis HGETALL asynchronously.
func (*Client) AsyncHincrby ¶ added in v0.2.0
AsyncHincrby calls Redis HINCRBY asynchronously.
func (*Client) AsyncHincrbyfloat ¶ added in v0.2.0
AsyncHincrbyfloat calls Redis HINCRBYFLOAT asynchronously.
func (*Client) AsyncHkeys ¶ added in v0.2.0
AsyncHkeys calls Redis HKEYS asynchronously.
func (*Client) AsyncHmget ¶ added in v0.2.0
AsyncHmget calls Redis HMGET asynchronously.
func (*Client) AsyncHmset ¶ added in v0.2.0
AsyncHmset calls Redis HMSET asynchronously.
func (*Client) AsyncHsetnx ¶ added in v0.2.0
AsyncHsetnx calls Redis HSETNX asynchronously.
func (*Client) AsyncHvals ¶ added in v0.2.0
AsyncHvals calls Redis HVALS asynchronously.
func (*Client) AsyncIncrby ¶ added in v0.2.0
AsyncIncrby calls Redis INCRBY asynchronously.
func (*Client) AsyncIncrbyfloat ¶ added in v0.2.0
AsyncIncrbyfloat calls Redis INCRBYFLOAT asynchronously.
func (*Client) AsyncLastsave ¶ added in v0.2.0
AsyncLastsave calls Redis LASTSAVE asynchronously.
func (*Client) AsyncLindex ¶ added in v0.2.0
AsyncLindex calls Redis LINDEX asynchronously.
func (*Client) AsyncLinsert ¶ added in v0.2.0
AsyncLinsert calls Redis LINSERT asynchronously.
func (*Client) AsyncLpush ¶ added in v0.2.0
AsyncLpush calls Redis LPUSH asynchronously.
func (*Client) AsyncLpushx ¶ added in v0.2.0
AsyncLpushx calls Redis LPUSHX asynchronously.
func (*Client) AsyncLrange ¶ added in v0.2.0
AsyncLrange calls Redis LRANGE asynchronously.
func (*Client) AsyncLtrim ¶ added in v0.2.0
AsyncLtrim calls Redis LTRIM asynchronously.
func (*Client) AsyncMigrate ¶ added in v0.2.0
AsyncMigrate calls Redis MIGRATE asynchronously.
func (*Client) AsyncMonitor ¶ added in v0.2.0
AsyncMonitor calls Redis MONITOR asynchronously.
func (*Client) AsyncMsetnx ¶ added in v0.2.0
AsyncMsetnx calls Redis MSETNX asynchronously.
func (*Client) AsyncMulti ¶ added in v0.2.0
AsyncMulti calls Redis MULTI asynchronously.
func (*Client) AsyncMultiCall ¶ added in v0.2.1
AsyncMultiCall calls an asynchronous MultiCall.
func (*Client) AsyncObject ¶ added in v0.2.0
AsyncObject calls Redis OBJECT asynchronously.
func (*Client) AsyncPersist ¶ added in v0.2.0
AsyncPersist calls Redis PERSIST asynchronously.
func (*Client) AsyncPexpire ¶ added in v0.2.0
AsyncPexpire calls Redis PEXPIRE asynchronously.
func (*Client) AsyncPexpireat ¶ added in v0.2.0
AsyncPexpireat calls Redis PEXPIREAT asynchronously.
func (*Client) AsyncPsetex ¶ added in v0.2.0
AsyncPsetex calls Redis PSETEX asynchronously.
func (*Client) AsyncPsubscribe ¶ added in v0.2.0
AsyncPsubscribe calls Redis PSUBSCRIBE asynchronously.
func (*Client) AsyncPublish ¶ added in v0.2.0
AsyncPublish calls Redis PUBLISH asynchronously.
func (*Client) AsyncPunsubscribe ¶ added in v0.2.0
AsyncPunsubscribe calls Redis PUNSUBSCRIBE asynchronously.
func (*Client) AsyncRandomkey ¶ added in v0.2.0
AsyncRandomkey calls Redis RANDOMKEY asynchronously.
func (*Client) AsyncRename ¶ added in v0.2.0
AsyncRename calls Redis RENAME asynchronously.
func (*Client) AsyncRenamenx ¶ added in v0.2.0
AsyncRenamenx calls Redis RENAMENX asynchronously.
func (*Client) AsyncReplconf ¶ added in v0.3.0
AsyncReplconf calls Redis REPLCONF asynchronously.
func (*Client) AsyncRestore ¶ added in v0.2.0
AsyncRestore calls Redis RESTORE asynchronously.
func (*Client) AsyncRpoplpush ¶ added in v0.2.0
AsyncRpoplpush calls Redis RPOPLPUSH asynchronously.
func (*Client) AsyncRpush ¶ added in v0.2.0
AsyncRpush calls Redis RPUSH asynchronously.
func (*Client) AsyncRpushx ¶ added in v0.2.0
AsyncRpushx calls Redis RPUSHX asynchronously.
func (*Client) AsyncScard ¶ added in v0.2.0
AsyncScard calls Redis SCARD asynchronously.
func (*Client) AsyncScript ¶ added in v0.2.0
AsyncScript calls Redis SCRIPT asynchronously.
func (*Client) AsyncSdiff ¶ added in v0.2.0
AsyncSdiff calls Redis SDIFF asynchronously.
func (*Client) AsyncSdiffstore ¶ added in v0.2.0
AsyncSdiffstore calls Redis SDIFFSTORE asynchronously.
func (*Client) AsyncSelect ¶ added in v0.2.0
AsyncSelect calls Redis SELECT asynchronously.
func (*Client) AsyncSetbit ¶ added in v0.2.0
AsyncSetbit calls Redis SETBIT asynchronously.
func (*Client) AsyncSetex ¶ added in v0.2.0
AsyncSetex calls Redis SETEX asynchronously.
func (*Client) AsyncSetnx ¶ added in v0.2.0
AsyncSetnx calls Redis SETNX asynchronously.
func (*Client) AsyncSetrange ¶ added in v0.2.0
AsyncSetrange calls Redis SETRANGE asynchronously.
func (*Client) AsyncShutdown ¶ added in v0.2.0
AsyncShutdown calls Redis SHUTDOWN asynchronously.
func (*Client) AsyncSinter ¶ added in v0.2.0
AsyncSinter calls Redis SINTER asynchronously.
func (*Client) AsyncSinterstore ¶ added in v0.2.0
AsyncSinterstore calls Redis SINTERSTORE asynchronously.
func (*Client) AsyncSismember ¶ added in v0.2.0
AsyncSismember calls Redis SISMEMBER asynchronously.
func (*Client) AsyncSlaveof ¶ added in v0.2.0
AsyncSlaveof calls Redis SLAVEOF asynchronously.
func (*Client) AsyncSmembers ¶ added in v0.2.0
AsyncSmembers calls Redis SMEMBERS asynchronously.
func (*Client) AsyncSmove ¶ added in v0.2.0
AsyncSmove calls Redis SMOVE asynchronously.
func (*Client) AsyncSrandmember ¶ added in v0.2.0
AsyncSrandmember calls Redis SRANDMEMBER asynchronously.
func (*Client) AsyncStrlen ¶ added in v0.2.0
AsyncStrlen calls Redis STRLEN asynchronously.
func (*Client) AsyncSubscribe ¶ added in v0.2.0
AsyncSubscribe calls Redis SUBSCRIBE asynchronously.
func (*Client) AsyncSunion ¶ added in v0.2.0
AsyncSunion calls Redis SUNION asynchronously.
func (*Client) AsyncSunionstore ¶ added in v0.2.0
AsyncSunionstore calls Redis SUNIONSTORE asynchronously.
func (*Client) AsyncTransaction ¶
AsyncTransaction performs a simple asynchronous transaction.
func (*Client) AsyncUnsubscribe ¶ added in v0.2.0
AsyncUnsubscribe calls Redis UNSUBSCRIBE asynchronously.
func (*Client) AsyncUnwatch ¶ added in v0.2.0
AsyncUnwatch calls Redis UNWATCH asynchronously.
func (*Client) AsyncWatch ¶ added in v0.2.0
AsyncWatch calls Redis WATCH asynchronously.
func (*Client) AsyncZcard ¶ added in v0.2.0
AsyncZcard calls Redis ZCARD asynchronously.
func (*Client) AsyncZcount ¶ added in v0.2.0
AsyncZcount calls Redis ZCOUNT asynchronously.
func (*Client) AsyncZincrby ¶ added in v0.2.0
AsyncZincrby calls Redis ZINCRBY asynchronously.
func (*Client) AsyncZinterstore ¶ added in v0.2.0
AsyncZinterstore calls Redis ZINTERSTORE asynchronously.
func (*Client) AsyncZrange ¶ added in v0.2.0
AsyncZrange calls Redis ZRANGE asynchronously.
func (*Client) AsyncZrangebyscore ¶ added in v0.2.0
AsyncZrangebyscore calls Redis ZRANGEBYSCORE asynchronously.
func (*Client) AsyncZrank ¶ added in v0.2.0
AsyncZrank calls Redis ZRANK asynchronously.
func (*Client) AsyncZremrangebyrank ¶ added in v0.2.0
AsyncZremrangebyrank calls Redis ZREMRANGEBYRANK asynchronously.
func (*Client) AsyncZremrangebyscore ¶ added in v0.2.0
AsyncZremrangebyscore calls Redis ZREMRANGEBYSCORE asynchronously.
func (*Client) AsyncZrevrange ¶ added in v0.2.0
AsyncZrevrange calls Redis ZREVRANGE asynchronously.
func (*Client) AsyncZrevrangebyscore ¶ added in v0.2.0
AsyncZrevrangebyscore calls Redis ZREVRANGEBYSCORE asynchronously.
func (*Client) AsyncZrevrank ¶ added in v0.2.0
AsyncZrevrank calls Redis ZREVRANK asynchronously.
func (*Client) AsyncZscore ¶ added in v0.2.0
AsyncZscore calls Redis ZSCORE asynchronously.
func (*Client) AsyncZunionstore ¶ added in v0.2.0
AsyncZunionstore calls Redis ZUNIONSTORE asynchronously.
func (*Client) Bgrewriteaof ¶ added in v0.2.0
Bgrewriteaof calls Redis BGREWRITEAOF command.
func (*Client) Brpoplpush ¶ added in v0.2.0
Brpoplpush calls Redis BRPOPLPUSH command.
func (*Client) Hincrbyfloat ¶ added in v0.2.0
Hincrbyfloat calls Redis HINCRBYFLOAT command.
func (*Client) Incrbyfloat ¶ added in v0.2.0
Incrbyfloat calls Redis INCRBYFLOAT command.
func (*Client) InfoMap ¶ added in v0.3.0
InfoMap calls the INFO command, parses and returns the results as a map[string]string or an error. Use Info method for fetching the unparsed INFO results.
func (*Client) MultiCall ¶ added in v0.2.1
MultiCall executes the given MultiCall. Multicall reply is guaranteed to have the same number of sub-replies as calls, if it succeeds.
func (*Client) Psubscribe ¶ added in v0.2.0
Psubscribe calls Redis PSUBSCRIBE command.
func (*Client) Punsubscribe ¶ added in v0.2.0
Punsubscribe calls Redis PUNSUBSCRIBE command.
func (*Client) Sdiffstore ¶ added in v0.2.0
Sdiffstore calls Redis SDIFFSTORE command.
func (*Client) Sinterstore ¶ added in v0.2.0
Sinterstore calls Redis SINTERSTORE command.
func (*Client) Srandmember ¶ added in v0.2.0
Srandmember calls Redis SRANDMEMBER command.
func (*Client) Subscription ¶
func (c *Client) Subscription(msgHdlr func(msg *Message)) (*Subscription, *Error)
Subscription returns a new Subscription instance with the given message handler callback or an error. The message handler is called whenever a new message arrives. Subscriptions create their own dedicated connections, they do not pull connections from the connection pool.
func (*Client) Sunionstore ¶ added in v0.2.0
Sunionstore calls Redis SUNIONSTORE command.
func (*Client) Transaction ¶
Transaction performs a simple transaction. Simple transaction is a multi command that is wrapped in a MULTI-EXEC block. For complex transactions with WATCH, UNWATCH or DISCARD commands use MultiCall. Transaction reply is guaranteed to have the same number of sub-replies as calls, if it succeeds.
func (*Client) Unsubscribe ¶ added in v0.2.0
Unsubscribe calls Redis UNSUBSCRIBE command.
func (*Client) Zinterstore ¶ added in v0.2.0
Zinterstore calls Redis ZINTERSTORE command.
func (*Client) Zrangebyscore ¶ added in v0.2.0
Zrangebyscore calls Redis ZRANGEBYSCORE command.
func (*Client) Zremrangebyrank ¶ added in v0.2.0
Zremrangebyrank calls Redis ZREMRANGEBYRANK command.
func (*Client) Zremrangebyscore ¶ added in v0.2.0
Zremrangebyscore calls Redis ZREMRANGEBYSCORE command.
func (*Client) Zrevrangebyscore ¶ added in v0.2.0
Zrevrangebyscore calls Redis ZREVRANGEBYSCORE command.
func (*Client) Zunionstore ¶ added in v0.2.0
Zunionstore calls Redis ZUNIONSTORE command.
type Config ¶ added in v0.1.5
type Config struct { // TCP/IP Address and unix path. Unix connections are prioritized if both are set. Address string // eg. "173.194.32.33:6379" Path string // eg. "/tmp/redis.sock" // Database number. Default: 0 Database int // Password for authentication. Leave as "" to not use authentication. // Default: "" Password string // Connection pool capacity. Default: 50 PoolCapacity int // Socket timeout. Default: 0 (no timeouts) Timeout time.Duration // Retry on LOADING error? Default: true RetryLoading bool }
Config is a configuration of a database client.
func DefaultConfig ¶ added in v0.3.0
func DefaultConfig() Config
DefaultConfig returns a new Config with default settings.
type Error ¶
type Error struct { Cmd Cmd // command that caused the error, if any // contains filtered or unexported fields }
type Future ¶
type Future chan *Reply
Future is a channel for fetching the reply of an asynchronous call.
type Message ¶
type Message struct { Type MessageType Channel string Pattern string Subscriptions int Payload string }
Message describes a pub/sub message
type MessageType ¶
type MessageType int
const ( MessageSubscribe MessageType = iota MessageUnsubscribe MessagePsubscribe MessagePunsubscribe MessageMessage MessagePmessage )
type MultiCall ¶ added in v0.2.1
type MultiCall struct {
// contains filtered or unexported fields
}
MultiCall holds data for multiple command calls.
func (*MultiCall) Append ¶ added in v0.2.1
func (mc *MultiCall) Append(args ...interface{})
Append queues a Redis APPEND command for later execution.
func (*MultiCall) Asking ¶ added in v0.2.1
func (mc *MultiCall) Asking(args ...interface{})
Asking queues a Redis ASKING command for later execution.
func (*MultiCall) Auth ¶ added in v0.2.1
func (mc *MultiCall) Auth(args ...interface{})
Auth queues a Redis AUTH command for later execution.
func (*MultiCall) Bgrewriteaof ¶ added in v0.2.1
func (mc *MultiCall) Bgrewriteaof(args ...interface{})
Bgrewriteaof queues a Redis BGREWRITEAOF command for later execution.
func (*MultiCall) Bgsave ¶ added in v0.2.1
func (mc *MultiCall) Bgsave(args ...interface{})
Bgsave queues a Redis BGSAVE command for later execution.
func (*MultiCall) Bitcount ¶ added in v0.3.0
func (mc *MultiCall) Bitcount(args ...interface{})
Bitcount queues a Redis BITCOUNT command for later execution.
func (*MultiCall) Bitop ¶ added in v0.3.0
func (mc *MultiCall) Bitop(args ...interface{})
Bitop queues a Redis BITOP command for later execution.
func (*MultiCall) Blpop ¶ added in v0.2.1
func (mc *MultiCall) Blpop(args ...interface{})
Blpop queues a Redis BLPOP command for later execution.
func (*MultiCall) Brpop ¶ added in v0.2.1
func (mc *MultiCall) Brpop(args ...interface{})
Brpop queues a Redis BRPOP command for later execution.
func (*MultiCall) Brpoplpush ¶ added in v0.2.1
func (mc *MultiCall) Brpoplpush(args ...interface{})
Brpoplpush queues a Redis BRPOPLPUSH command for later execution.
func (*MultiCall) Client ¶ added in v0.2.1
func (mc *MultiCall) Client(args ...interface{})
Client queues a Redis CLIENT command for later execution.
func (*MultiCall) Cluster ¶ added in v0.2.1
func (mc *MultiCall) Cluster(args ...interface{})
Cluster queues a Redis CLUSTER command for later execution.
func (*MultiCall) Config ¶ added in v0.2.1
func (mc *MultiCall) Config(args ...interface{})
Config queues a Redis CONFIG command for later execution.
func (*MultiCall) Dbsize ¶ added in v0.2.1
func (mc *MultiCall) Dbsize(args ...interface{})
Dbsize queues a Redis DBSIZE command for later execution.
func (*MultiCall) Debug ¶ added in v0.2.1
func (mc *MultiCall) Debug(args ...interface{})
Debug queues a Redis DEBUG command for later execution.
func (*MultiCall) Decr ¶ added in v0.2.1
func (mc *MultiCall) Decr(args ...interface{})
Decr queues a Redis DECR command for later execution.
func (*MultiCall) Decrby ¶ added in v0.2.1
func (mc *MultiCall) Decrby(args ...interface{})
Decrby queues a Redis DECRBY command for later execution.
func (*MultiCall) Del ¶ added in v0.2.1
func (mc *MultiCall) Del(args ...interface{})
Del queues a Redis DEL command for later execution.
func (*MultiCall) Discard ¶ added in v0.2.1
func (mc *MultiCall) Discard(args ...interface{})
Discard queues a Redis DISCARD command for later execution.
func (*MultiCall) Dump ¶ added in v0.2.1
func (mc *MultiCall) Dump(args ...interface{})
Dump queues a Redis DUMP command for later execution.
func (*MultiCall) Echo ¶ added in v0.2.1
func (mc *MultiCall) Echo(args ...interface{})
Echo queues a Redis ECHO command for later execution.
func (*MultiCall) Eval ¶ added in v0.2.1
func (mc *MultiCall) Eval(args ...interface{})
Eval queues a Redis EVAL command for later execution.
func (*MultiCall) Exec ¶ added in v0.2.1
func (mc *MultiCall) Exec(args ...interface{})
Exec queues a Redis EXEC command for later execution.
func (*MultiCall) Exists ¶ added in v0.2.1
func (mc *MultiCall) Exists(args ...interface{})
Exists queues a Redis EXISTS command for later execution.
func (*MultiCall) Expire ¶ added in v0.2.1
func (mc *MultiCall) Expire(args ...interface{})
Expire queues a Redis EXPIRE command for later execution.
func (*MultiCall) Expireat ¶ added in v0.2.1
func (mc *MultiCall) Expireat(args ...interface{})
Expireat queues a Redis EXPIREAT command for later execution.
func (*MultiCall) Flush ¶ added in v0.2.1
Flush sends queued calls to the server for execution and returns the returned Reply.
func (*MultiCall) Flushall ¶ added in v0.2.1
func (mc *MultiCall) Flushall(args ...interface{})
Flushall queues a Redis FLUSHALL command for later execution.
func (*MultiCall) Flushdb ¶ added in v0.2.1
func (mc *MultiCall) Flushdb(args ...interface{})
Flushdb queues a Redis FLUSHDB command for later execution.
func (*MultiCall) Get ¶ added in v0.2.1
func (mc *MultiCall) Get(args ...interface{})
Get queues a Redis GET command for later execution.
func (*MultiCall) Getbit ¶ added in v0.2.1
func (mc *MultiCall) Getbit(args ...interface{})
Getbit queues a Redis GETBIT command for later execution.
func (*MultiCall) Getrange ¶ added in v0.2.1
func (mc *MultiCall) Getrange(args ...interface{})
Getrange queues a Redis GETRANGE command for later execution.
func (*MultiCall) Getset ¶ added in v0.2.1
func (mc *MultiCall) Getset(args ...interface{})
Getset queues a Redis GETSET command for later execution.
func (*MultiCall) Hdel ¶ added in v0.2.1
func (mc *MultiCall) Hdel(args ...interface{})
Hdel queues a Redis HDEL command for later execution.
func (*MultiCall) Hexists ¶ added in v0.2.1
func (mc *MultiCall) Hexists(args ...interface{})
Hexists queues a Redis HEXISTS command for later execution.
func (*MultiCall) Hget ¶ added in v0.2.1
func (mc *MultiCall) Hget(args ...interface{})
Hget queues a Redis HGET command for later execution.
func (*MultiCall) Hgetall ¶ added in v0.2.1
func (mc *MultiCall) Hgetall(args ...interface{})
Hgetall queues a Redis HGETALL command for later execution.
func (*MultiCall) Hincrby ¶ added in v0.2.1
func (mc *MultiCall) Hincrby(args ...interface{})
Hincrby queues a Redis HINCRBY command for later execution.
func (*MultiCall) Hincrbyfloat ¶ added in v0.2.1
func (mc *MultiCall) Hincrbyfloat(args ...interface{})
Hincrbyfloat queues a Redis HINCRBYFLOAT command for later execution.
func (*MultiCall) Hkeys ¶ added in v0.2.1
func (mc *MultiCall) Hkeys(args ...interface{})
Hkeys queues a Redis HKEYS command for later execution.
func (*MultiCall) Hlen ¶ added in v0.2.1
func (mc *MultiCall) Hlen(args ...interface{})
Hlen queues a Redis HLEN command for later execution.
func (*MultiCall) Hmget ¶ added in v0.2.1
func (mc *MultiCall) Hmget(args ...interface{})
Hmget queues a Redis HMGET command for later execution.
func (*MultiCall) Hmset ¶ added in v0.2.1
func (mc *MultiCall) Hmset(args ...interface{})
Hmset queues a Redis HMSET command for later execution.
func (*MultiCall) Hset ¶ added in v0.2.1
func (mc *MultiCall) Hset(args ...interface{})
Hset queues a Redis HSET command for later execution.
func (*MultiCall) Hsetnx ¶ added in v0.2.1
func (mc *MultiCall) Hsetnx(args ...interface{})
Hsetnx queues a Redis HSETNX command for later execution.
func (*MultiCall) Hvals ¶ added in v0.2.1
func (mc *MultiCall) Hvals(args ...interface{})
Hvals queues a Redis HVALS command for later execution.
func (*MultiCall) Incr ¶ added in v0.2.1
func (mc *MultiCall) Incr(args ...interface{})
Incr queues a Redis INCR command for later execution.
func (*MultiCall) Incrby ¶ added in v0.2.1
func (mc *MultiCall) Incrby(args ...interface{})
Incrby queues a Redis INCRBY command for later execution.
func (*MultiCall) Incrbyfloat ¶ added in v0.2.1
func (mc *MultiCall) Incrbyfloat(args ...interface{})
Incrbyfloat queues a Redis INCRBYFLOAT command for later execution.
func (*MultiCall) Info ¶ added in v0.2.1
func (mc *MultiCall) Info(args ...interface{})
Info queues a Redis INFO command for later execution.
func (*MultiCall) Keys ¶ added in v0.2.1
func (mc *MultiCall) Keys(args ...interface{})
Keys queues a Redis KEYS command for later execution.
func (*MultiCall) Lastsave ¶ added in v0.2.1
func (mc *MultiCall) Lastsave(args ...interface{})
Lastsave queues a Redis LASTSAVE command for later execution.
func (*MultiCall) Lindex ¶ added in v0.2.1
func (mc *MultiCall) Lindex(args ...interface{})
Lindex queues a Redis LINDEX command for later execution.
func (*MultiCall) Linsert ¶ added in v0.2.1
func (mc *MultiCall) Linsert(args ...interface{})
Linsert queues a Redis LINSERT command for later execution.
func (*MultiCall) Llen ¶ added in v0.2.1
func (mc *MultiCall) Llen(args ...interface{})
Llen queues a Redis LLEN command for later execution.
func (*MultiCall) Lpop ¶ added in v0.2.1
func (mc *MultiCall) Lpop(args ...interface{})
Lpop queues a Redis LPOP command for later execution.
func (*MultiCall) Lpush ¶ added in v0.2.1
func (mc *MultiCall) Lpush(args ...interface{})
Lpush queues a Redis LPUSH command for later execution.
func (*MultiCall) Lpushx ¶ added in v0.2.1
func (mc *MultiCall) Lpushx(args ...interface{})
Lpushx queues a Redis LPUSHX command for later execution.
func (*MultiCall) Lrange ¶ added in v0.2.1
func (mc *MultiCall) Lrange(args ...interface{})
Lrange queues a Redis LRANGE command for later execution.
func (*MultiCall) Lrem ¶ added in v0.2.1
func (mc *MultiCall) Lrem(args ...interface{})
Lrem queues a Redis LREM command for later execution.
func (*MultiCall) Lset ¶ added in v0.2.1
func (mc *MultiCall) Lset(args ...interface{})
Lset queues a Redis LSET command for later execution.
func (*MultiCall) Ltrim ¶ added in v0.2.1
func (mc *MultiCall) Ltrim(args ...interface{})
Ltrim queues a Redis LTRIM command for later execution.
func (*MultiCall) Mget ¶ added in v0.2.1
func (mc *MultiCall) Mget(args ...interface{})
Mget queues a Redis MGET command for later execution.
func (*MultiCall) Migrate ¶ added in v0.2.1
func (mc *MultiCall) Migrate(args ...interface{})
Migrate queues a Redis MIGRATE command for later execution.
func (*MultiCall) Monitor ¶ added in v0.2.1
func (mc *MultiCall) Monitor(args ...interface{})
Monitor queues a Redis MONITOR command for later execution.
func (*MultiCall) Move ¶ added in v0.2.1
func (mc *MultiCall) Move(args ...interface{})
Move queues a Redis MOVE command for later execution.
func (*MultiCall) Mset ¶ added in v0.2.1
func (mc *MultiCall) Mset(args ...interface{})
Mset queues a Redis MSET command for later execution.
func (*MultiCall) Msetnx ¶ added in v0.2.1
func (mc *MultiCall) Msetnx(args ...interface{})
Msetnx queues a Redis MSETNX command for later execution.
func (*MultiCall) Multi ¶ added in v0.2.1
func (mc *MultiCall) Multi(args ...interface{})
Multi queues a Redis MULTI command for later execution.
func (*MultiCall) Object ¶ added in v0.2.1
func (mc *MultiCall) Object(args ...interface{})
Object queues a Redis OBJECT command for later execution.
func (*MultiCall) Persist ¶ added in v0.2.1
func (mc *MultiCall) Persist(args ...interface{})
Persist queues a Redis PERSIST command for later execution.
func (*MultiCall) Pexpire ¶ added in v0.2.1
func (mc *MultiCall) Pexpire(args ...interface{})
Pexpire queues a Redis PEXPIRE command for later execution.
func (*MultiCall) Pexpireat ¶ added in v0.2.1
func (mc *MultiCall) Pexpireat(args ...interface{})
Pexpireat queues a Redis PEXPIREAT command for later execution.
func (*MultiCall) Ping ¶ added in v0.2.1
func (mc *MultiCall) Ping(args ...interface{})
Ping queues a Redis PING command for later execution.
func (*MultiCall) Psetex ¶ added in v0.2.1
func (mc *MultiCall) Psetex(args ...interface{})
Psetex queues a Redis PSETEX command for later execution.
func (*MultiCall) Psubscribe ¶ added in v0.2.1
func (mc *MultiCall) Psubscribe(args ...interface{})
Psubscribe queues a Redis PSUBSCRIBE command for later execution.
func (*MultiCall) Pttl ¶ added in v0.2.1
func (mc *MultiCall) Pttl(args ...interface{})
Pttl queues a Redis PTTL command for later execution.
func (*MultiCall) Publish ¶ added in v0.2.1
func (mc *MultiCall) Publish(args ...interface{})
Publish queues a Redis PUBLISH command for later execution.
func (*MultiCall) Punsubscribe ¶ added in v0.2.1
func (mc *MultiCall) Punsubscribe(args ...interface{})
Punsubscribe queues a Redis PUNSUBSCRIBE command for later execution.
func (*MultiCall) Randomkey ¶ added in v0.2.1
func (mc *MultiCall) Randomkey(args ...interface{})
Randomkey queues a Redis RANDOMKEY command for later execution.
func (*MultiCall) Rename ¶ added in v0.2.1
func (mc *MultiCall) Rename(args ...interface{})
Rename queues a Redis RENAME command for later execution.
func (*MultiCall) Renamenx ¶ added in v0.2.1
func (mc *MultiCall) Renamenx(args ...interface{})
Renamenx queues a Redis RENAMENX command for later execution.
func (*MultiCall) Replconf ¶ added in v0.3.0
func (mc *MultiCall) Replconf(args ...interface{})
Replconf queues a Redis REPLCONF command for later execution.
func (*MultiCall) Restore ¶ added in v0.2.1
func (mc *MultiCall) Restore(args ...interface{})
Restore queues a Redis RESTORE command for later execution.
func (*MultiCall) Rpop ¶ added in v0.2.1
func (mc *MultiCall) Rpop(args ...interface{})
Rpop queues a Redis RPOP command for later execution.
func (*MultiCall) Rpoplpush ¶ added in v0.2.1
func (mc *MultiCall) Rpoplpush(args ...interface{})
Rpoplpush queues a Redis RPOPLPUSH command for later execution.
func (*MultiCall) Rpush ¶ added in v0.2.1
func (mc *MultiCall) Rpush(args ...interface{})
Rpush queues a Redis RPUSH command for later execution.
func (*MultiCall) Rpushx ¶ added in v0.2.1
func (mc *MultiCall) Rpushx(args ...interface{})
Rpushx queues a Redis RPUSHX command for later execution.
func (*MultiCall) Sadd ¶ added in v0.2.1
func (mc *MultiCall) Sadd(args ...interface{})
Sadd queues a Redis SADD command for later execution.
func (*MultiCall) Save ¶ added in v0.2.1
func (mc *MultiCall) Save(args ...interface{})
Save queues a Redis SAVE command for later execution.
func (*MultiCall) Scard ¶ added in v0.2.1
func (mc *MultiCall) Scard(args ...interface{})
Scard queues a Redis SCARD command for later execution.
func (*MultiCall) Script ¶ added in v0.2.1
func (mc *MultiCall) Script(args ...interface{})
Script queues a Redis SCRIPT command for later execution.
func (*MultiCall) Sdiff ¶ added in v0.2.1
func (mc *MultiCall) Sdiff(args ...interface{})
Sdiff queues a Redis SDIFF command for later execution.
func (*MultiCall) Sdiffstore ¶ added in v0.2.1
func (mc *MultiCall) Sdiffstore(args ...interface{})
Sdiffstore queues a Redis SDIFFSTORE command for later execution.
func (*MultiCall) Select ¶ added in v0.2.1
func (mc *MultiCall) Select(args ...interface{})
Select queues a Redis SELECT command for later execution.
func (*MultiCall) Set ¶ added in v0.2.1
func (mc *MultiCall) Set(args ...interface{})
Set queues a Redis SET command for later execution.
func (*MultiCall) Setbit ¶ added in v0.2.1
func (mc *MultiCall) Setbit(args ...interface{})
Setbit queues a Redis SETBIT command for later execution.
func (*MultiCall) Setex ¶ added in v0.2.1
func (mc *MultiCall) Setex(args ...interface{})
Setex queues a Redis SETEX command for later execution.
func (*MultiCall) Setnx ¶ added in v0.2.1
func (mc *MultiCall) Setnx(args ...interface{})
Setnx queues a Redis SETNX command for later execution.
func (*MultiCall) Setrange ¶ added in v0.2.1
func (mc *MultiCall) Setrange(args ...interface{})
Setrange queues a Redis SETRANGE command for later execution.
func (*MultiCall) Shutdown ¶ added in v0.2.1
func (mc *MultiCall) Shutdown(args ...interface{})
Shutdown queues a Redis SHUTDOWN command for later execution.
func (*MultiCall) Sinter ¶ added in v0.2.1
func (mc *MultiCall) Sinter(args ...interface{})
Sinter queues a Redis SINTER command for later execution.
func (*MultiCall) Sinterstore ¶ added in v0.2.1
func (mc *MultiCall) Sinterstore(args ...interface{})
Sinterstore queues a Redis SINTERSTORE command for later execution.
func (*MultiCall) Sismember ¶ added in v0.2.1
func (mc *MultiCall) Sismember(args ...interface{})
Sismember queues a Redis SISMEMBER command for later execution.
func (*MultiCall) Slaveof ¶ added in v0.2.1
func (mc *MultiCall) Slaveof(args ...interface{})
Slaveof queues a Redis SLAVEOF command for later execution.
func (*MultiCall) Smembers ¶ added in v0.2.1
func (mc *MultiCall) Smembers(args ...interface{})
Smembers queues a Redis SMEMBERS command for later execution.
func (*MultiCall) Smove ¶ added in v0.2.1
func (mc *MultiCall) Smove(args ...interface{})
Smove queues a Redis SMOVE command for later execution.
func (*MultiCall) Sort ¶ added in v0.2.1
func (mc *MultiCall) Sort(args ...interface{})
Sort queues a Redis SORT command for later execution.
func (*MultiCall) Spop ¶ added in v0.2.1
func (mc *MultiCall) Spop(args ...interface{})
Spop queues a Redis SPOP command for later execution.
func (*MultiCall) Srandmember ¶ added in v0.2.1
func (mc *MultiCall) Srandmember(args ...interface{})
Srandmember queues a Redis SRANDMEMBER command for later execution.
func (*MultiCall) Srem ¶ added in v0.2.1
func (mc *MultiCall) Srem(args ...interface{})
Srem queues a Redis SREM command for later execution.
func (*MultiCall) Strlen ¶ added in v0.2.1
func (mc *MultiCall) Strlen(args ...interface{})
Strlen queues a Redis STRLEN command for later execution.
func (*MultiCall) Subscribe ¶ added in v0.2.1
func (mc *MultiCall) Subscribe(args ...interface{})
Subscribe queues a Redis SUBSCRIBE command for later execution.
func (*MultiCall) Sunion ¶ added in v0.2.1
func (mc *MultiCall) Sunion(args ...interface{})
Sunion queues a Redis SUNION command for later execution.
func (*MultiCall) Sunionstore ¶ added in v0.2.1
func (mc *MultiCall) Sunionstore(args ...interface{})
Sunionstore queues a Redis SUNIONSTORE command for later execution.
func (*MultiCall) Sync ¶ added in v0.2.1
func (mc *MultiCall) Sync(args ...interface{})
Sync queues a Redis SYNC command for later execution.
func (*MultiCall) Time ¶ added in v0.2.1
func (mc *MultiCall) Time(args ...interface{})
Time queues a Redis TIME command for later execution.
func (*MultiCall) Ttl ¶ added in v0.2.1
func (mc *MultiCall) Ttl(args ...interface{})
Ttl queues a Redis TTL command for later execution.
func (*MultiCall) Type ¶ added in v0.2.1
func (mc *MultiCall) Type(args ...interface{})
Type queues a Redis TYPE command for later execution.
func (*MultiCall) Unsubscribe ¶ added in v0.2.1
func (mc *MultiCall) Unsubscribe(args ...interface{})
Unsubscribe queues a Redis UNSUBSCRIBE command for later execution.
func (*MultiCall) Unwatch ¶ added in v0.2.1
func (mc *MultiCall) Unwatch(args ...interface{})
Unwatch queues a Redis UNWATCH command for later execution.
func (*MultiCall) Watch ¶ added in v0.2.1
func (mc *MultiCall) Watch(args ...interface{})
Watch queues a Redis WATCH command for later execution.
func (*MultiCall) Zadd ¶ added in v0.2.1
func (mc *MultiCall) Zadd(args ...interface{})
Zadd queues a Redis ZADD command for later execution.
func (*MultiCall) Zcard ¶ added in v0.2.1
func (mc *MultiCall) Zcard(args ...interface{})
Zcard queues a Redis ZCARD command for later execution.
func (*MultiCall) Zcount ¶ added in v0.2.1
func (mc *MultiCall) Zcount(args ...interface{})
Zcount queues a Redis ZCOUNT command for later execution.
func (*MultiCall) Zincrby ¶ added in v0.2.1
func (mc *MultiCall) Zincrby(args ...interface{})
Zincrby queues a Redis ZINCRBY command for later execution.
func (*MultiCall) Zinterstore ¶ added in v0.2.1
func (mc *MultiCall) Zinterstore(args ...interface{})
Zinterstore queues a Redis ZINTERSTORE command for later execution.
func (*MultiCall) Zrange ¶ added in v0.2.1
func (mc *MultiCall) Zrange(args ...interface{})
Zrange queues a Redis ZRANGE command for later execution.
func (*MultiCall) Zrangebyscore ¶ added in v0.2.1
func (mc *MultiCall) Zrangebyscore(args ...interface{})
Zrangebyscore queues a Redis ZRANGEBYSCORE command for later execution.
func (*MultiCall) Zrank ¶ added in v0.2.1
func (mc *MultiCall) Zrank(args ...interface{})
Zrank queues a Redis ZRANK command for later execution.
func (*MultiCall) Zrem ¶ added in v0.2.1
func (mc *MultiCall) Zrem(args ...interface{})
Zrem queues a Redis ZREM command for later execution.
func (*MultiCall) Zremrangebyrank ¶ added in v0.2.1
func (mc *MultiCall) Zremrangebyrank(args ...interface{})
Zremrangebyrank queues a Redis ZREMRANGEBYRANK command for later execution.
func (*MultiCall) Zremrangebyscore ¶ added in v0.2.1
func (mc *MultiCall) Zremrangebyscore(args ...interface{})
Zremrangebyscore queues a Redis ZREMRANGEBYSCORE command for later execution.
func (*MultiCall) Zrevrange ¶ added in v0.2.1
func (mc *MultiCall) Zrevrange(args ...interface{})
Zrevrange queues a Redis ZREVRANGE command for later execution.
func (*MultiCall) Zrevrangebyscore ¶ added in v0.2.1
func (mc *MultiCall) Zrevrangebyscore(args ...interface{})
Zrevrangebyscore queues a Redis ZREVRANGEBYSCORE command for later execution.
func (*MultiCall) Zrevrank ¶ added in v0.2.1
func (mc *MultiCall) Zrevrank(args ...interface{})
Zrevrank queues a Redis ZREVRANK command for later execution.
func (*MultiCall) Zscore ¶ added in v0.2.1
func (mc *MultiCall) Zscore(args ...interface{})
Zscore queues a Redis ZSCORE command for later execution.
func (*MultiCall) Zunionstore ¶ added in v0.2.1
func (mc *MultiCall) Zunionstore(args ...interface{})
Zunionstore queues a Redis ZUNIONSTORE command for later execution.
type Reply ¶
type Reply struct { Type ReplyType // Reply type Elems []*Reply // Sub-replies Err *Error // Reply error // contains filtered or unexported fields }
Reply holds a Redis reply.
func (*Reply) Bool ¶
Bool returns true, if the reply value equals to 1 or "1", otherwise false; or an error, if the reply type is not ReplyInteger or ReplyString.
func (*Reply) Bytes ¶
Bytes is a convenience method for calling Reply.Str() and converting it to []byte.
func (*Reply) Hash ¶ added in v0.3.0
Map returns a multi-bulk reply as a map[string]string or an error. The reply type must be ReplyMulti, it must have an even number of elements, they must be in a "key value key value..." order and values must all be either ReplyString or ReplyNil. Nil values are returned as empty strings. Useful for hash commands.
func (*Reply) Int64 ¶
Int64 returns the reply value as a int64 or an error, if the reply type is not ReplyInteger or the reply type ReplyString could not be parsed to an int64.
func (*Reply) List ¶ added in v0.3.0
List returns a multi-bulk reply as a slice of strings or an error. The reply type must be ReplyMulti and its elements' types must all be either ReplyString or ReplyNil. Nil elements are returned as empty strings. Useful for list commands.
type ReplyType ¶
type ReplyType uint8
ReplyType describes type of a reply.
Possbile values are:
ReplyStatus -- status reply ReplyError -- error reply ReplyInteger -- integer reply ReplyNil -- nil reply ReplyString -- string reply (bulk reply) ReplyMulti -- multi-bulk or multicall reply
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
Subscription is a structure for holding a Redis subscription for multiple channels.
func (*Subscription) Psubscribe ¶ added in v0.2.0
func (s *Subscription) Psubscribe(patterns ...string) (err *Error)
Psubscribe subscribes to given patterns or returns an error.
func (*Subscription) Punsubscribe ¶ added in v0.2.0
func (s *Subscription) Punsubscribe(patterns ...string) (err *Error)
Punsubscribe unsubscribes from given patterns or returns an error.
func (*Subscription) Subscribe ¶
func (s *Subscription) Subscribe(channels ...string) (err *Error)
Subscribe subscribes to given channels or returns an error.
func (*Subscription) Unsubscribe ¶
func (s *Subscription) Unsubscribe(channels ...string) (err *Error)
Unsubscribe unsubscribes from given channels or returns an error.