state.h

Go to the documentation of this file.

 
#pragma once
 
#include <neograph/api.h>
#include <neograph/graph/types.h>
#include <mutex>
#include <shared_mutex>
#include <vector>
 
namespace neograph::graph {
 
class NEOGRAPH_API GraphState {
public:
    void init_channel(const std::string& name,
                      ReducerType type,
                      ReducerFn reducer,
                      const json& initial_value = json());
 
    json get(const std::string& channel) const;
 
    std::vector<ChatMessage> get_messages() const;
 
    void write(const std::string& channel, const json& value);
 
    void apply_writes(const std::vector<ChannelWrite>& writes);
 
    uint64_t channel_version(const std::string& channel) const;
 
    uint64_t global_version() const;
 
    json serialize() const;
 
    void restore(const json& data);
 
    std::vector<std::string> channel_names() const;
 
    // v1.0 (9d): the v0.3 `run_cancel_token_` smuggling channel is gone.
    // Cancel propagation now flows exclusively through
    // `RunContext::cancel_token` on `NodeInput::ctx` (engine threads it
    // through every dispatch; multi-Send fan-out copies the context by
    // value, so the cancel token survives the isolated-state boundary
    // without a serialize/restore hop).
 
private:
    std::map<std::string, Channel> channels_;
    uint64_t global_version_ = 0;
    mutable std::shared_mutex mutex_;
};
 
} // namespace neograph::graph