diff options
Diffstat (limited to 'common/storage/entitystore.h')
-rw-r--r-- | common/storage/entitystore.h | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/common/storage/entitystore.h b/common/storage/entitystore.h index 003a2ca..c89c095 100644 --- a/common/storage/entitystore.h +++ b/common/storage/entitystore.h | |||
@@ -39,6 +39,8 @@ public: | |||
39 | EntityStore(const ResourceContext &resourceContext, const Sink::Log::Context &); | 39 | EntityStore(const ResourceContext &resourceContext, const Sink::Log::Context &); |
40 | ~EntityStore() = default; | 40 | ~EntityStore() = default; |
41 | 41 | ||
42 | using ApplicationDomainType = ApplicationDomain::ApplicationDomainType; | ||
43 | |||
42 | void initialize(); | 44 | void initialize(); |
43 | 45 | ||
44 | //Only the pipeline may call the following functions outside of tests | 46 | //Only the pipeline may call the following functions outside of tests |
@@ -63,10 +65,14 @@ public: | |||
63 | return indexLookup(ApplicationDomain::getTypeName<EntityType>(), PropertyType::name, value, callback); | 65 | return indexLookup(ApplicationDomain::getTypeName<EntityType>(), PropertyType::name, value, callback); |
64 | } | 66 | } |
65 | 67 | ||
68 | ///Returns the uid and buffer. Note that the memory only remains valid until the next operation or transaction end. | ||
66 | void readLatest(const QByteArray &type, const QByteArray &uid, const std::function<void(const QByteArray &uid, const EntityBuffer &entity)> callback); | 69 | void readLatest(const QByteArray &type, const QByteArray &uid, const std::function<void(const QByteArray &uid, const EntityBuffer &entity)> callback); |
70 | ///Returns an entity. Note that the memory only remains valid until the next operation or transaction end. | ||
67 | void readLatest(const QByteArray &type, const QByteArray &uid, const std::function<void(const ApplicationDomain::ApplicationDomainType &entity)> callback); | 71 | void readLatest(const QByteArray &type, const QByteArray &uid, const std::function<void(const ApplicationDomain::ApplicationDomainType &entity)> callback); |
72 | ///Returns an entity and operation. Note that the memory only remains valid until the next operation or transaction end. | ||
68 | void readLatest(const QByteArray &type, const QByteArray &uid, const std::function<void(const ApplicationDomain::ApplicationDomainType &entity, Sink::Operation)> callback); | 73 | void readLatest(const QByteArray &type, const QByteArray &uid, const std::function<void(const ApplicationDomain::ApplicationDomainType &entity, Sink::Operation)> callback); |
69 | 74 | ||
75 | ///Returns a copy | ||
70 | ApplicationDomain::ApplicationDomainType readLatest(const QByteArray &type, const QByteArray &uid); | 76 | ApplicationDomain::ApplicationDomainType readLatest(const QByteArray &type, const QByteArray &uid); |
71 | 77 | ||
72 | template<typename T> | 78 | template<typename T> |
@@ -74,8 +80,11 @@ public: | |||
74 | return T(readLatest(ApplicationDomain::getTypeName<T>(), uid)); | 80 | return T(readLatest(ApplicationDomain::getTypeName<T>(), uid)); |
75 | } | 81 | } |
76 | 82 | ||
83 | ///Returns the uid and buffer. Note that the memory only remains valid until the next operation or transaction end. | ||
77 | void readEntity(const QByteArray &type, const QByteArray &uid, const std::function<void(const QByteArray &uid, const EntityBuffer &entity)> callback); | 84 | void readEntity(const QByteArray &type, const QByteArray &uid, const std::function<void(const QByteArray &uid, const EntityBuffer &entity)> callback); |
85 | ///Returns an entity. Note that the memory only remains valid until the next operation or transaction end. | ||
78 | void readEntity(const QByteArray &type, const QByteArray &uid, const std::function<void(const ApplicationDomain::ApplicationDomainType &entity)> callback); | 86 | void readEntity(const QByteArray &type, const QByteArray &uid, const std::function<void(const ApplicationDomain::ApplicationDomainType &entity)> callback); |
87 | ///Returns a copy | ||
79 | ApplicationDomain::ApplicationDomainType readEntity(const QByteArray &type, const QByteArray &key); | 88 | ApplicationDomain::ApplicationDomainType readEntity(const QByteArray &type, const QByteArray &key); |
80 | 89 | ||
81 | template<typename T> | 90 | template<typename T> |
@@ -86,6 +95,7 @@ public: | |||
86 | 95 | ||
87 | void readPrevious(const QByteArray &type, const QByteArray &uid, qint64 revision, const std::function<void(const QByteArray &uid, const EntityBuffer &entity)> callback); | 96 | void readPrevious(const QByteArray &type, const QByteArray &uid, qint64 revision, const std::function<void(const QByteArray &uid, const EntityBuffer &entity)> callback); |
88 | void readPrevious(const QByteArray &type, const QByteArray &uid, qint64 revision, const std::function<void(const ApplicationDomain::ApplicationDomainType &entity)> callback); | 97 | void readPrevious(const QByteArray &type, const QByteArray &uid, qint64 revision, const std::function<void(const ApplicationDomain::ApplicationDomainType &entity)> callback); |
98 | ///Returns a copy | ||
89 | ApplicationDomain::ApplicationDomainType readPrevious(const QByteArray &type, const QByteArray &uid, qint64 revision); | 99 | ApplicationDomain::ApplicationDomainType readPrevious(const QByteArray &type, const QByteArray &uid, qint64 revision); |
90 | 100 | ||
91 | template<typename T> | 101 | template<typename T> |