ObserverManager.h

Go to the documentation of this file.

/*
 * This file is part of KnowRob, please consult
 * https://github.com/knowrob/knowrob for license details.
 */
 
#ifndef KNOWROB_OBSERVER_MANAGER_H
#define KNOWROB_OBSERVER_MANAGER_H
 
#include <memory>
#include <knowrob/semweb/GraphQuery.h>
#include <knowrob/storage/Transaction.h>
#include "Observer.h"
 
namespace knowrob {
    class ObserverManager : public std::enable_shared_from_this<ObserverManager> {
    public:
        explicit ObserverManager(const QueryableBackendPtr &backend);
 
        ~ObserverManager();
 
        void stop();
 
        ObserverPtr observe(const GraphQueryPtr &query, const BindingsHandler &callback);
 
        void synchronize();
 
        void stopObservation(const Observer &observer);
 
        void insert(const TripleContainerPtr &triples);
 
        void remove(const TripleContainerPtr &triples);
 
        void query(const GraphQueryPtr &query, const BindingsHandler &callback);
 
    protected:
        struct Impl;
        std::unique_ptr<Impl> impl_;
        QueryableBackendPtr backend_;
 
        void run();
    };
 
    using ObserverManagerPtr = std::shared_ptr<ObserverManager>;
 
} // knowrob
 
#endif //KNOWROB_OBSERVER_MANAGER_H