Entity.h

Go to the documentation of this file.

#pragma once
 
#include <memory>
 
// Base Class
#include "EntitySnapshot.h"
#include "detail/EntityBase.h"
 
#include "persistence/MemoryPersistenceStrategy.h"
 
namespace armarx::armem::server::ltm
{
    /// @brief A memory storing data in mongodb (needs 'armarx memory start' to start the mongod instance)
    class Entity :
        public detail::EntityBase<EntitySnapshot>
    {
    public:
        Entity(const std::string& exportName,
               const MemoryID& memoryId,
               const std::shared_ptr<Processors>& filters,
               const std::shared_ptr<persistence::MemoryPersistenceStrategy>& persistenceStrategy);
 
        bool hasSnapshot(const Time& snapshotTime) const override;
 
        bool forEachSnapshot(std::function<void(EntitySnapshot&)> func) const override;
        bool forEachSnapshotInIndexRange(long first,
                                         long last,
                                         std::function<void(EntitySnapshot&)> func) const override;
        bool forEachSnapshotInTimeRange(const Time& min,
                                        const Time& max,
                                        std::function<void(EntitySnapshot&)> func) const override;
        bool forEachSnapshotBeforeOrAt(const Time& time,
                                       std::function<void(EntitySnapshot&)> func) const override;
        bool forEachSnapshotBefore(const Time& time,
                                   std::function<void(EntitySnapshot&)> func) const override;
 
        std::shared_ptr<EntitySnapshot> findSnapshot(const Time& snapshotTime) const override;
        std::shared_ptr<EntitySnapshot> findLatestSnapshot() const override;
        std::shared_ptr<EntitySnapshot> findLatestSnapshotBefore(const Time& time) const override;
        std::shared_ptr<EntitySnapshot>
        findLatestSnapshotBeforeOrAt(const Time& time) const override;
        std::shared_ptr<EntitySnapshot> findFirstSnapshotAfter(const Time& time) const override;
        std::shared_ptr<EntitySnapshot> findFirstSnapshotAfterOrAt(const Time& time) const override;
 
    protected:
        void _loadAllReferences(armem::wm::Entity& wmEntity) override;
        void _loadLatestNReferences(int n, armem::wm::Entity& wmEntity) override;
        void _resolve(armem::wm::Entity& wmEntity) override;
        void _store(const armem::wm::Entity& wmEntity, bool simulatedVersion) override;
 
    private:
        std::shared_ptr<persistence::MemoryPersistenceStrategy> persistenceStrategy_;
    };
 
} // namespace armarx::armem::server::ltm