summaryrefslogtreecommitdiffstats
path: root/common/storage/entitystore.h
diff options
context:
space:
mode:
Diffstat (limited to 'common/storage/entitystore.h')
-rw-r--r--common/storage/entitystore.h30
1 files changed, 15 insertions, 15 deletions
diff --git a/common/storage/entitystore.h b/common/storage/entitystore.h
index c89c095..d79a0b5 100644
--- a/common/storage/entitystore.h
+++ b/common/storage/entitystore.h
@@ -44,12 +44,12 @@ public:
44 void initialize(); 44 void initialize();
45 45
46 //Only the pipeline may call the following functions outside of tests 46 //Only the pipeline may call the following functions outside of tests
47 bool add(const QByteArray &type, ApplicationDomain::ApplicationDomainType newEntity, bool replayToSource); 47 bool add(const QByteArray &type, ApplicationDomainType newEntity, bool replayToSource);
48 bool modify(const QByteArray &type, const ApplicationDomain::ApplicationDomainType &diff, const QByteArrayList &deletions, bool replayToSource); 48 bool modify(const QByteArray &type, const ApplicationDomainType &diff, const QByteArrayList &deletions, bool replayToSource);
49 bool modify(const QByteArray &type, const ApplicationDomain::ApplicationDomainType &current, ApplicationDomain::ApplicationDomainType newEntity, bool replayToSource); 49 bool modify(const QByteArray &type, const ApplicationDomainType &current, ApplicationDomainType newEntity, bool replayToSource);
50 bool remove(const QByteArray &type, const ApplicationDomain::ApplicationDomainType &current, bool replayToSource); 50 bool remove(const QByteArray &type, const ApplicationDomainType &current, bool replayToSource);
51 bool cleanupRevisions(qint64 revision); 51 bool cleanupRevisions(qint64 revision);
52 ApplicationDomain::ApplicationDomainType applyDiff(const QByteArray &type, const ApplicationDomain::ApplicationDomainType &current, const ApplicationDomain::ApplicationDomainType &diff, const QByteArrayList &deletions) const; 52 ApplicationDomainType applyDiff(const QByteArray &type, const ApplicationDomainType &current, const ApplicationDomainType &diff, const QByteArrayList &deletions) const;
53 53
54 void startTransaction(Sink::Storage::DataStore::AccessMode); 54 void startTransaction(Sink::Storage::DataStore::AccessMode);
55 void commitTransaction(); 55 void commitTransaction();
@@ -68,12 +68,12 @@ public:
68 ///Returns the uid and buffer. Note that the memory only remains valid until the next operation or transaction end. 68 ///Returns the uid and buffer. Note that the memory only remains valid until the next operation or transaction end.
69 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. 70 ///Returns an entity. Note that the memory only remains valid until the next operation or transaction end.
71 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 ApplicationDomainType &entity)> callback);
72 ///Returns an entity and operation. Note that the memory only remains valid until the next operation or transaction end. 72 ///Returns an entity and operation. Note that the memory only remains valid until the next operation or transaction end.
73 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 ApplicationDomainType &entity, Sink::Operation)> callback);
74 74
75 ///Returns a copy 75 ///Returns a copy
76 ApplicationDomain::ApplicationDomainType readLatest(const QByteArray &type, const QByteArray &uid); 76 ApplicationDomainType readLatest(const QByteArray &type, const QByteArray &uid);
77 77
78 template<typename T> 78 template<typename T>
79 T readLatest(const QByteArray &uid) { 79 T readLatest(const QByteArray &uid) {
@@ -83,9 +83,9 @@ public:
83 ///Returns the uid and buffer. Note that the memory only remains valid until the next operation or transaction end. 83 ///Returns the uid and buffer. Note that the memory only remains valid until the next operation or transaction end.
84 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. 85 ///Returns an entity. Note that the memory only remains valid until the next operation or transaction end.
86 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 ApplicationDomainType &entity)> callback);
87 ///Returns a copy 87 ///Returns a copy
88 ApplicationDomain::ApplicationDomainType readEntity(const QByteArray &type, const QByteArray &key); 88 ApplicationDomainType readEntity(const QByteArray &type, const QByteArray &key);
89 89
90 template<typename T> 90 template<typename T>
91 T readEntity(const QByteArray &key) { 91 T readEntity(const QByteArray &key) {
@@ -94,9 +94,9 @@ public:
94 94
95 95
96 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);
97 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 ApplicationDomainType &entity)> callback);
98 ///Returns a copy 98 ///Returns a copy
99 ApplicationDomain::ApplicationDomainType readPrevious(const QByteArray &type, const QByteArray &uid, qint64 revision); 99 ApplicationDomainType readPrevious(const QByteArray &type, const QByteArray &uid, qint64 revision);
100 100
101 template<typename T> 101 template<typename T>
102 T readPrevious(const QByteArray &uid, qint64 revision) { 102 T readPrevious(const QByteArray &uid, qint64 revision) {
@@ -105,11 +105,11 @@ public:
105 105
106 void readAllUids(const QByteArray &type, const std::function<void(const QByteArray &uid)> callback); 106 void readAllUids(const QByteArray &type, const std::function<void(const QByteArray &uid)> callback);
107 107
108 void readAll(const QByteArray &type, const std::function<void(const ApplicationDomain::ApplicationDomainType &entity)> &callback); 108 void readAll(const QByteArray &type, const std::function<void(const ApplicationDomainType &entity)> &callback);
109 109
110 template<typename T> 110 template<typename T>
111 void readAll(const std::function<void(const T &entity)> &callback) { 111 void readAll(const std::function<void(const T &entity)> &callback) {
112 return readAll(ApplicationDomain::getTypeName<T>(), [&](const ApplicationDomain::ApplicationDomainType &entity) { 112 return readAll(ApplicationDomain::getTypeName<T>(), [&](const ApplicationDomainType &entity) {
113 callback(T(entity)); 113 callback(T(entity));
114 }); 114 });
115 } 115 }
@@ -131,7 +131,7 @@ private:
131 * Remove any old revisions of the same entity up until @param revision 131 * Remove any old revisions of the same entity up until @param revision
132 */ 132 */
133 void cleanupEntityRevisionsUntil(qint64 revision); 133 void cleanupEntityRevisionsUntil(qint64 revision);
134 void copyBlobs(ApplicationDomain::ApplicationDomainType &entity, qint64 newRevision); 134 void copyBlobs(ApplicationDomainType &entity, qint64 newRevision);
135 class Private; 135 class Private;
136 const QSharedPointer<Private> d; 136 const QSharedPointer<Private> d;
137}; 137};