diff options
Diffstat (limited to 'common/storage/entitystore.h')
-rw-r--r-- | common/storage/entitystore.h | 30 |
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 ¤t, ApplicationDomain::ApplicationDomainType newEntity, bool replayToSource); | 49 | bool modify(const QByteArray &type, const ApplicationDomainType ¤t, ApplicationDomainType newEntity, bool replayToSource); |
50 | bool remove(const QByteArray &type, const ApplicationDomain::ApplicationDomainType ¤t, bool replayToSource); | 50 | bool remove(const QByteArray &type, const ApplicationDomainType ¤t, bool replayToSource); |
51 | bool cleanupRevisions(qint64 revision); | 51 | bool cleanupRevisions(qint64 revision); |
52 | ApplicationDomain::ApplicationDomainType applyDiff(const QByteArray &type, const ApplicationDomain::ApplicationDomainType ¤t, const ApplicationDomain::ApplicationDomainType &diff, const QByteArrayList &deletions) const; | 52 | ApplicationDomainType applyDiff(const QByteArray &type, const ApplicationDomainType ¤t, 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 | }; |