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);
 
    protected:
        // Implementation methods
        bool _implHasSnapshot(const Time& snapshotTime) const override;
 
        bool _implForEachSnapshot(std::function<void(EntitySnapshot&)> func) const override;
        bool _implForEachSnapshotInIndexRange(long first,
                                              long last,
                                              std::function<void(EntitySnapshot&)> func) const override;
        bool _implForEachSnapshotInTimeRange(const Time& min,
                                             const Time& max,
                                             std::function<void(EntitySnapshot&)> func) const override;
        bool _implForEachSnapshotBeforeOrAt(const Time& time,
                                            std::function<void(EntitySnapshot&)> func) const override;
        bool _implForEachSnapshotBefore(const Time& time,
                                        std::function<void(EntitySnapshot&)> func) const override;
        bool _implForEachSnapshotBeforeReverse(const Time& time,
                                               std::function<bool(EntitySnapshot&)> func) const override;
 
        std::shared_ptr<EntitySnapshot> _implFindSnapshot(const Time& snapshotTime) const override;
        std::shared_ptr<EntitySnapshot> _implFindLatestSnapshot() const override;
        std::shared_ptr<EntitySnapshot> _implFindLatestSnapshotBefore(const Time& time) const override;
        std::shared_ptr<EntitySnapshot>
        _implFindLatestSnapshotBeforeOrAt(const Time& time) const override;
        std::shared_ptr<EntitySnapshot> _implFindFirstSnapshotAfter(const Time& time) const override;
        std::shared_ptr<EntitySnapshot> _implFindFirstSnapshotAfterOrAt(const Time& time) const override;
 
        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