store.h

Go to the documentation of this file.

 
#pragma once
 
#include <neograph/api.h>
#include <neograph/types.h>
#include <string>
#include <vector>
#include <optional>
#include <mutex>
#include <map>
#include <chrono>
#include <tuple>
 
namespace neograph::graph {
 
using Namespace = std::vector<std::string>;
 
struct StoreItem {
    Namespace   ns;          
    std::string key;         
    json        value;       
    int64_t     created_at;  
    int64_t     updated_at;  
};
 
class NEOGRAPH_API Store {
public:
    virtual ~Store() = default;
 
    virtual void put(const Namespace& ns, const std::string& key, const json& value) = 0;
 
    virtual std::optional<StoreItem> get(const Namespace& ns, const std::string& key) const = 0;
 
    virtual std::vector<StoreItem> search(const Namespace& ns_prefix, int limit = 100) const = 0;
 
    virtual void delete_item(const Namespace& ns, const std::string& key) = 0;
 
    virtual std::vector<Namespace> list_namespaces(const Namespace& prefix = {}) const = 0;
};
 
class NEOGRAPH_API InMemoryStore : public Store {
public:
    void put(const Namespace& ns, const std::string& key, const json& value) override;
    std::optional<StoreItem> get(const Namespace& ns, const std::string& key) const override;
    std::vector<StoreItem> search(const Namespace& ns_prefix, int limit = 100) const override;
    void delete_item(const Namespace& ns, const std::string& key) override;
    std::vector<Namespace> list_namespaces(const Namespace& prefix = {}) const override;
 
    size_t size() const;
 
private:
    static std::string make_key(const Namespace& ns, const std::string& key);
    static std::string ns_to_string(const Namespace& ns);
    static bool starts_with(const std::string& str, const std::string& prefix);
 
    mutable std::mutex mutex_;
    std::map<std::string, StoreItem> items_;
};
 
} // namespace neograph::graph