cross_server_storage.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_SERVICE_CROSS_SERVER_STORAGE_H_
#define INCLUDE_FUNAPI_SERVICE_CROSS_SERVER_STORAGE_H_

#include <boost/noncopyable.hpp>
#include <funapi/common/json.h>
#include <funapi/time/wall_clock.h>
#include <funapi/types.h>


namespace fun {

class FUNAPI_DLL_VISIBILITY CrossServerStorage : private boost::noncopyable {
 public:
  enum Result {
    kSuccess = 0,
    kNotExist,
    kDuplicated,
    kInvalidParameter,
    kInternalError
  };

  typedef Uuid Key;

  typedef function<void(const Key &key, Result result)> Callback;
  typedef function<void(const Key &key,
                        const Json &data, Result result)> ReadCallback;

  // Async
  static void Create(const Key &key, const Json &data,
                     const WallClock::Duration &expiration_time,
                     const Callback &cb);

  static void Create(const Json &data,
                     const WallClock::Duration &expiration_time,
                     const Callback &cb);

  static void Delete(const Key &key, const Callback &cb);

  static void Read(const Key &key, const ReadCallback &cb);

  static void Write(const Key &key, const Json &data,
                    const WallClock::Duration &expiration_time,
                    const Callback &cb);

  static void Refresh(const Key &key,
                      const WallClock::Duration &expiration_time,
                      const Callback &cb);

  // Sync
  static Result CreateSync(const Key &key, const Json &data,
                           const WallClock::Duration &expiration_time);

  static Result CreateSync(const Json &data,
                           const WallClock::Duration &expiration_time,
                           Key *key);

  static Result DeleteSync(const Key &key);

  static Result ReadSync(const Key &key, Json *data);

  static Result WriteSync(const Key &key, const Json &data,
                          const WallClock::Duration &expiration_time);

  static Result RefreshSync(const Key &key,
                            const WallClock::Duration &expiration_time);
};

}  // namespace fun

#endif  // INCLUDE_FUNAPI_SERVICE_CROSS_SERVER_STORAGE_H_