redis_client.h

Go to the documentation of this file.

// Copyright (C) 2013-2020 iFunFactory Inc. All Rights Reserved.
//
// This work is confidential and proprietary to iFunFactory Inc. and
// must not be used, disclosed, copied, or distributed without the prior
// consent of iFunFactory Inc.
//

#ifndef INCLUDE_FUNAPI_DATABASE_REDIS_CLIENT_H_
#define INCLUDE_FUNAPI_DATABASE_REDIS_CLIENT_H_

#include <funapi/common/json.h>
#include <funapi/types.h>

#include <string>
#include <vector>


namespace fun {

class FUNAPI_DLL_VISIBILITY RedisClient {
 public:
  struct FUNAPI_DLL_VISIBILITY Result {
    enum Type {
      kError = 0,
      kSuccess = 1,
      kNil = 2,
    };

    Result();

    Type type;
    int error_code;
    string error_desc;
  };

  struct FUNAPI_DLL_VISIBILITY Reply {
    enum Type {
      kString = 1,
      kArray = 2,
      kInteger = 3,
      kNil = 4,
      kStatus = 5,
      kError = 6
    };

    DECLARE_CLASS_PTR(Reply);

    Type type;
    int64_t integer;
    string str;
    std::vector<Ptr<Reply> > elements;
  };

  enum CommandOption {
    kNone = 0,

    kEX,
    kPX,
    kNX,
    kXX,

    kAND,
    kOR,
    kXOR,
    kNOT,

    kBEFORE,
    kAFTER
  };

  typedef std::vector<string> StringList;
  typedef std::pair<string, string> StringPair;
  typedef std::vector<StringPair> StringPairList;
  typedef std::pair<string, double> StringDoublePair;
  typedef std::vector<StringDoublePair> StringDoublePairList;

  typedef function<void(const Result &, const Ptr<Reply> &)> Callback;
  typedef function<void(const Result &, int64_t)> IntegerCallback;
  typedef function<void(const Result &, double)> DoubleCallback;
  typedef function<void(const Result &, const string &)> StringCallback;
  typedef function<void(const Result &, const StringList &)> StringListCallback;
  typedef function<void(const Result &,
                        const StringPairList &)> StringPairListCallback;
  typedef function<
      void(const Result &,
           const StringDoublePairList &)> StringDoublePairListCallback;

  typedef function<void(const string &/*channel*/,
                        const string &/*message*/)> SubCallback;
  typedef function<void(const string &/*pattern*/,
                        const string &/*channel*/,
                        const string &/*message*/)> PSubCallback;

  typedef boost::function<
      void (const string &/*master_name*/,
            const string &/*old_master_address*/,
            const string &/*new_master_address*/)>
                SentinelMasterSwitchedCallback;

  typedef function<void(size_t /*connection_index*/)> DisconnectCallback;

  typedef Uuid SerializationTag;
  static const SerializationTag kDefaultSerializationTag;

  static Ptr<RedisClient> Create(const string &server_ip,
                                 int server_port,
                                 const string &auth_pass,
                                 size_t connection_count,
                                 bool invoke_as_event = true,
                                 size_t database = 0);

  static Ptr<RedisClient> Create(const string &master_name,
                                 const std::vector<string> &sentinel_addresses,
                                 const string &auth_pass,
                                 size_t connection_count,
                                 bool invoke_as_event = true,
                                 size_t database = 0);

  void Initialize();
  void Finalize(bool immediately = false);

  size_t GetConnectedConnectionCount() const;

  void SetProfiling(bool is_on);
  void DumpProfilingResult(Json *out);

  void RegisterDisconnectCallback(const DisconnectCallback &callback);

  void SetSentinelMasterSwitchedCallback(
      const SentinelMasterSwitchedCallback &callback);

  bool invoke_as_event() const;

  void Del(const string &key, const IntegerCallback &callback,
           const SerializationTag &tag = kDefaultSerializationTag);
  void Del(const StringList &keys, const IntegerCallback &callback,
           const SerializationTag &tag = kDefaultSerializationTag);
  void Exists(const string &key, const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void Expire(const string &key, uint64_t seconds,
              const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void PExpire(const string &key, uint64_t milliseconds,
               const IntegerCallback &callback,
               const SerializationTag &tag = kDefaultSerializationTag);
  void Persist(const string &key, const IntegerCallback &callback,
               const SerializationTag &tag = kDefaultSerializationTag);
  void TTL(const string &key, const IntegerCallback &callback,
           const SerializationTag &tag = kDefaultSerializationTag);
  void PTTL(const string &key, const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void Rename(const string &key, const string &new_key,
              const StringCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);

  Result DelSync(const string &key, int64_t *out);
  Result DelSync(const StringList &keys, int64_t *out);
  Result ExistsSync(const string &key, int64_t *out);
  Result ExpireSync(const string &key, uint64_t seconds, int64_t *out);
  Result PExpireSync(const string &key, uint64_t milliseconds, int64_t *out);
  Result PersistSync(const string &key, int64_t *out);
  Result TTLSync(const string &key, int64_t *out);
  Result PTTLSync(const string &key, int64_t *out);
  Result RenameSync(const string &key, const string &new_key, string *out);

  void Append(const string &key, const string &value,
              const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void Incr(const string &key, const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void IncrBy(const string &key, int64_t increment,
              const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void IncrByFloat(const string &key, double increment,
                   const DoubleCallback &callback,
                   const SerializationTag &tag = kDefaultSerializationTag);
  void Decr(const string &key, const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void DecrBy(const string &key, int64_t decrement,
              const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void StrLen(const string &key, const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void Get(const string &key, const StringCallback &callback,
           const SerializationTag &tag = kDefaultSerializationTag);
  void MGet(const StringList &keys, const StringListCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void GetRange(const string &key, int64_t start, int64_t end,
                const StringCallback &callback,
                const SerializationTag &tag = kDefaultSerializationTag);
  void GetSet(const string &key, const string &value,
              const StringCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void Set(const string &key, const string &value,
           const StringCallback &callback,
           const SerializationTag &tag = kDefaultSerializationTag);
  void Set(const string &key, const string &value,
           CommandOption ex_or_px, uint64_t time,
           CommandOption nx_or_xx, const StringCallback &callback,
           const SerializationTag &tag = kDefaultSerializationTag);
  void SetEx(const string &key, uint64_t seconds, const string &value,
             const StringCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void PSetEx(const string &key, uint64_t milliseconds,
              const string &value, const StringCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void SetNx(const string &key, const string &value,
             const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void MSet(const StringPairList &key_values, const StringCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void MSetNx(const StringPairList &key_values,
              const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void BitCount(const string &key, const IntegerCallback &callback,
                const SerializationTag &tag = kDefaultSerializationTag);
  void BitCount(const string &key, int64_t start, int64_t end,
                const IntegerCallback &callback,
                const SerializationTag &tag = kDefaultSerializationTag);
  void BitOp(CommandOption operation, const string &dest_key,
             const StringList &keys, const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void GetBit(const string &key, uint64_t offset,
              const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void SetBit(const string &key, uint64_t offset, bool value,
              const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);

  Result AppendSync(const string &key, const string &value, int64_t *out);
  Result IncrSync(const string &key, int64_t *out);
  Result IncrBySync(const string &key, int64_t increment, int64_t *out);
  Result IncrByFloatSync(const string &key, double increment, double *out);
  Result DecrSync(const string &key, int64_t *out);
  Result DecrBySync(const string &key, int64_t decrement, int64_t *out);
  Result StrLenSync(const string &key, int64_t *out);
  Result GetSync(const string &key, string *out);
  Result MGetSync(const StringList &keys, StringList *out);
  Result GetRangeSync(const string &key, int64_t start, int64_t end,
                      string *out);
  Result GetSetSync(const string &key, const string &value, string *out);
  Result SetSync(const string &key, const string &value, string *out);
  Result SetSync(const string &key, const string &value,
                 CommandOption ex_or_px, uint64_t time,
                 CommandOption nx_or_xx, string *out);
  Result SetExSync(const string &key, uint64_t seconds, const string &value,
                  string *out);
  Result PSetExSync(const string &key, uint64_t milliseconds,
                    const string &value, string *out);
  Result SetNxSync(const string &key, const string &value, int64_t *out);
  Result MSetSync(const StringPairList &key_values, string *out);
  Result MSetNxSync(const StringPairList &key_values, int64_t *out);
  Result BitCountSync(const string &key, int64_t *out);
  Result BitCountSync(const string &key, int64_t start, int64_t end,
                      int64_t *out);
  Result BitOpSync(CommandOption operation, const string &dest_key,
                   const StringList &keys, int64_t *out);
  Result GetBitSync(const string &key, uint64_t offset, int64_t *out);
  Result SetBitSync(const string &key, uint64_t offset, bool value,
                    int64_t *out);

  void HExists(const string &key, const string &field,
               const IntegerCallback &callback,
               const SerializationTag &tag = kDefaultSerializationTag);
  void HKeys(const string &key, const StringListCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void HVals(const string &key, const StringListCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void HLen(const string &key, const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void HIncrBy(const string &key, const string &field, int64_t increment,
               const IntegerCallback &callback,
               const SerializationTag &tag = kDefaultSerializationTag);
  void HIncrByFloat(const string &key, const string &field,
                    double increment, const DoubleCallback &callback,
                    const SerializationTag &tag = kDefaultSerializationTag);
  void HDel(const string &key, const string &field,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void HDel(const string &key, const StringList &fields,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void HGet(const string &key, const string &field,
            const StringCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void HGetAll(const string &key, const StringPairListCallback &callback,
               const SerializationTag &tag = kDefaultSerializationTag);
  void HMGet(const string &key, const StringList &fields,
             const StringListCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void HSet(const string &key, const string &field, const string &value,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void HSetNx(const string &key, const string &field, const string &value,
              const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void HMSet(const string &key, const StringPairList &field_values,
             const StringCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);

  Result HExistsSync(const string &key, const string &field, int64_t *out);
  Result HKeysSync(const string &key, StringList *out);
  Result HValsSync(const string &key, StringList *out);
  Result HLenSync(const string &key, int64_t *out);
  Result HIncrBySync(const string &key, const string &field,
                     int64_t increment, int64_t *out);
  Result HIncrByFloatSync(const string &key, const string &field,
                          double increment, double *out);
  Result HDelSync(const string &key, const string &field, int64_t *out);
  Result HDelSync(const string &key, const StringList &fields, int64_t *out);
  Result HGetSync(const string &key, const string &field, string *out);
  Result HGetAllSync(const string &key, StringPairList *out);
  Result HMGetSync(const string &key, const StringList &fields,
                   StringList *out);
  Result HSetSync(const string &key, const string &field, const string &value,
                  int64_t *out);
  Result HSetNxSync(const string &key, const string &field, const string &value,
                    int64_t *out);
  Result HMSetSync(const string &key, const StringPairList &field_values,
                   string *out);

  void LLen(const string &key, const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void LIndex(const string &key, int64_t index, const StringCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void LRange(const string &key, int64_t start, int64_t stop,
              const StringListCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void LRem(const string &key, int64_t count, const string &value,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void LTrim(const string &key, int64_t start, int64_t stop,
             const StringCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void LPush(const string &key, const string &value,
             const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void LPush(const string &key, const StringList &values,
             const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void RPush(const string &key, const string &value,
             const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void RPush(const string &key, const StringList &values,
             const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void LPop(const string &key, const StringCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void RPop(const string &key, const StringCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void LInsert(const string &key, CommandOption before_or_after,
               const string &pivot, const string &value,
               const IntegerCallback &callback,
               const SerializationTag &tag = kDefaultSerializationTag);
  void LSet(const string &key, int64_t index, const string &value,
            const StringCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);

  Result LLenSync(const string &key, int64_t *out);
  Result LIndexSync(const string &key, int64_t index, string *out);
  Result LRangeSync(const string &key, int64_t start, int64_t stop,
                    StringList *out);
  Result LRemSync(const string &key, int64_t count, const string &value,
                  int64_t *out);
  Result LTrimSync(const string &key, int64_t start, int64_t stop,
                   string *out);
  Result LPushSync(const string &key, const string &value, int64_t *out);
  Result LPushSync(const string &key, const StringList &values,
                   int64_t *out);
  Result RPushSync(const string &key, const string &value, int64_t *out);
  Result RPushSync(const string &key, const StringList &values, int64_t *out);
  Result LPopSync(const string &key, string *out);
  Result RPopSync(const string &key, string *out);
  Result LInsertSync(const string &key, CommandOption before_or_after,
                     const string &pivot, const string &value, int64_t *out);
  Result LSetSync(const string &key, int64_t index, const string &value,
                  string *out);

  void SCard(const string &key, const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void SIsMember(const string &key, const string &member,
                 const IntegerCallback &callback,
                 const SerializationTag &tag = kDefaultSerializationTag);
  void SMembers(const string &key, const StringListCallback &callback,
                const SerializationTag &tag = kDefaultSerializationTag);
  void SRandMember(const string &key, const StringCallback &callback,
                   const SerializationTag &tag = kDefaultSerializationTag);
  void SRandMember(const string &key, int64_t count,
                   const StringListCallback &callback,
                   const SerializationTag &tag = kDefaultSerializationTag);
  void SDiff(const StringList &keys, const StringListCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void SDiffStore(const string &destination, const StringList &keys,
                  const IntegerCallback &callback,
                  const SerializationTag &tag = kDefaultSerializationTag);
  void SInter(const StringList &keys, const StringListCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void SInterStore(const string &destination, const StringList &keys,
                   const IntegerCallback &callback,
                   const SerializationTag &tag = kDefaultSerializationTag);
  void SUnion(const StringList &keys, const StringListCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void SUnionStore(const string &destination, const StringList &keys,
                   const IntegerCallback &callback,
                   const SerializationTag &tag = kDefaultSerializationTag);
  void SAdd(const string &key, const string &member,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void SAdd(const string &key, const StringList &members,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void SPop(const string &key, const StringCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void SRem(const string &key, const string &member,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void SRem(const string &key, const StringList &members,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void SMove(const string &source, const string &destination,
             const string &member, const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);

  Result SCardSync(const string &key, int64_t *out);
  Result SIsMemberSync(const string &key, const string &member, int64_t *out);
  Result SMembersSync(const string &key, StringList *out);
  Result SRandMemberSync(const string &key, string *out);
  Result SRandMemberSync(const string &key, int64_t count, StringList *out);
  Result SDiffSync(const StringList &keys, StringList *out);
  Result SDiffStoreSync(const string &destination, const StringList &keys,
                        int64_t *out);
  Result SInterSync(const StringList &keys, StringList *out);
  Result SInterStoreSync(const string &destination, const StringList &keys,
                         int64_t *out);
  Result SUnionSync(const StringList &keys, StringList *out);
  Result SUnionStoreSync(const string &destination, const StringList &keys,
                         int64_t *out);
  Result SAddSync(const string &key, const string &member,
                  int64_t *out);
  Result SAddSync(const string &key, const StringList &members,
                  int64_t *out);
  Result SPopSync(const string &key, string *out);
  Result SRemSync(const string &key, const string &member, int64_t *out);
  Result SRemSync(const string &key, const StringList &members,
                  int64_t *out);
  Result SMoveSync(const string &source, const string &destination,
                   const string &member, int64_t *out);

  void ZCard(const string &key, const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void ZCount(const string &key, const string &min, const string &max,
              const IntegerCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void ZScore(const string &key, const string &member,
              const DoubleCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void ZRange(const string &key, int64_t start, int64_t stop,
              bool with_scores, const StringDoublePairListCallback &callback,
              const SerializationTag &tag = kDefaultSerializationTag);
  void ZRangeByScore(const string &key, const string &min, const string &max,
                     bool with_scores,
                     const StringDoublePairListCallback &callback,
                     const SerializationTag &tag = kDefaultSerializationTag);
  void ZRangeByScore(const string &key, const string &min, const string &max,
                     bool with_scores, uint64_t offset, uint64_t count,
                     const StringDoublePairListCallback &callback,
                     const SerializationTag &tag = kDefaultSerializationTag);
  void ZRank(const string &key, const string &member,
             const IntegerCallback &callback,
             const SerializationTag &tag = kDefaultSerializationTag);
  void ZRevRange(const string &key, int64_t start, int64_t stop,
                 bool with_scores,
                 const StringDoublePairListCallback &callback,
                 const SerializationTag &tag = kDefaultSerializationTag);
  void ZRevRangeByScore(const string &key, const string &max, const string &min,
                        bool with_scores,
                        const StringDoublePairListCallback &callback,
                        const SerializationTag &tag = kDefaultSerializationTag);
  void ZRevRangeByScore(const string &key, const string &max, const string &min,
                        bool with_scores, uint64_t offset, uint64_t count,
                        const StringDoublePairListCallback &callback,
                        const SerializationTag &tag = kDefaultSerializationTag);
  void ZRevRank(const string &key, const string &member,
                const IntegerCallback &callback,
                const SerializationTag &tag = kDefaultSerializationTag);
  void ZAdd(const string &key, double score, const string &member,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void ZAdd(const string &key, const StringDoublePairList &score_members,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void ZIncrBy(const string &key, double increment, const string &member,
               const DoubleCallback &callback,
               const SerializationTag &tag = kDefaultSerializationTag);
  void ZRem(const string &key, const string &member,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void ZRem(const string &key, const StringList &members,
            const IntegerCallback &callback,
            const SerializationTag &tag = kDefaultSerializationTag);
  void ZRemRangeByRank(const string &key, int64_t start, int64_t stop,
                       const IntegerCallback &callback,
                       const SerializationTag &tag = kDefaultSerializationTag);
  void ZRemRangeByScore(const string &key, const string &min, const string &max,
                        const IntegerCallback &callback,
                        const SerializationTag &tag = kDefaultSerializationTag);

  Result ZCardSync(const string &key, int64_t *out);
  Result ZCountSync(const string &key, const string &min, const string &max,
                    int64_t *out);
  Result ZScoreSync(const string &key, const string &member, double *out);
  Result ZRangeSync(const string &key, int64_t start, int64_t stop,
                    bool with_scores, StringDoublePairList *out);
  Result ZRangeByScoreSync(const string &key, const string &min,
                           const string &max, bool with_scores,
                           StringDoublePairList *out);
  Result ZRangeByScoreSync(const string &key, const string &min,
                           const string &max, bool with_scores,
                           uint64_t offset, uint64_t count,
                           StringDoublePairList *out);
  Result ZRankSync(const string &key, const string &member, int64_t *out);
  Result ZRevRangeSync(const string &key, int64_t start, int64_t stop,
                       bool with_scores, StringDoublePairList *out);
  Result ZRevRangeByScoreSync(const string &key, const string &max,
                              const string &min, bool with_scores,
                              StringDoublePairList *out);
  Result ZRevRangeByScoreSync(const string &key, const string &max,
                              const string &min, bool with_scores,
                              uint64_t offset, uint64_t count,
                              StringDoublePairList *out);
  Result ZRevRankSync(const string &key, const string &member, int64_t *out);
  Result ZAddSync(const string &key, double score, const string &member,
                  int64_t *out);
  Result ZAddSync(const string &key, const StringDoublePairList &score_members,
                  int64_t *out);
  Result ZIncrBySync(const string &key, double increment, const string &member,
                     double *out);
  Result ZRemSync(const string &key, const string &member, int64_t *out);
  Result ZRemSync(const string &key, const StringList &members, int64_t *out);
  Result ZRemRangeByRankSync(const string &key, int64_t start, int64_t stop,
                             int64_t *out);
  Result ZRemRangeByScoreSync(const string &key, const string &min,
                              const string &max, int64_t *out);

  void Publish(const string &channel, const string &message,
               const IntegerCallback &callback,
               const SerializationTag &tag = kDefaultSerializationTag);
  void Subscribe(const string &channel, const SubCallback &callback);
  void Subscribe(const std::vector<string> &channels,
                 const SubCallback &callback);
  void PSubscribe(const string &pattern, const PSubCallback &callback);
  void PSubscribe(const std::vector<string> &patterns,
                  const PSubCallback &callback);
  void Unsubscribe();
  void Unsubscribe(const string &channel);
  void Unsubscribe(const std::vector<string> &channels);
  void PUnsubscribe();
  void PUnsubscribe(const string &pattern);
  void PUnsubscribe(const std::vector<string> &patterns);

  Result PublishSync(const string &channel, const string &message,
                     int64_t *out);

  void ExecuteCommand(const string &command_name,
                      const std::vector<string> *arguments,
                      const Callback &callback,
                      const SerializationTag &tag = kDefaultSerializationTag);
  Ptr<Reply> ExecuteCommandSync(const string &command_name,
                                const std::vector<string> *arguments,
                                Result *result = NULL);

 private:
  class Impl;

  RedisClient(const string &server_ip, int server_port,
              const string &auth_pass, size_t connection_count,
              bool invoke_as_event, size_t database);

  RedisClient(const string &master_name,
              const std::vector<string> &sentinel_addresses,
              const string &auth_pass, size_t connection_count,
              bool invoke_as_event, size_t database);

  Ptr<Impl> impl_;
};


FUNAPI_DLL_VISIBILITY
std::ostream &operator<<(std::ostream &stream,
                         const RedisClient::Result &result);

}  // namespace fun

#endif  // INCLUDE_FUNAPI_DATABASE_REDIS_CLIENT_H_