summaryrefslogtreecommitdiffstats
path: root/common/datastorequery.h
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2018-02-22 10:16:18 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2018-02-22 10:16:18 +0100
commit2beb09e8b3f4922a15ec0abde737d4cf9b9d4f8b (patch)
tree50115abf9b041d66ab9e4242af52cd16a7a9a3db /common/datastorequery.h
parent280b1250c0a038c2cf09fae3848ed0adefecc430 (diff)
downloadsink-2beb09e8b3f4922a15ec0abde737d4cf9b9d4f8b.tar.gz
sink-2beb09e8b3f4922a15ec0abde737d4cf9b9d4f8b.zip
Deal with removals in reduced queries
Diffstat (limited to 'common/datastorequery.h')
-rw-r--r--common/datastorequery.h7
1 files changed, 7 insertions, 0 deletions
diff --git a/common/datastorequery.h b/common/datastorequery.h
index 8800644..2311585 100644
--- a/common/datastorequery.h
+++ b/common/datastorequery.h
@@ -62,6 +62,7 @@ private:
62 QVector<QByteArray> indexLookup(const QByteArray &property, const QVariant &value); 62 QVector<QByteArray> indexLookup(const QByteArray &property, const QVariant &value);
63 63
64 void readEntity(const QByteArray &key, const BufferCallback &resultCallback); 64 void readEntity(const QByteArray &key, const BufferCallback &resultCallback);
65 void readPrevious(const QByteArray &key, const std::function<void (const Sink::ApplicationDomain::ApplicationDomainType &)> &callback);
65 66
66 ResultSet createFilteredSet(ResultSet &resultSet, const FilterFunction &); 67 ResultSet createFilteredSet(ResultSet &resultSet, const FilterFunction &);
67 QVector<QByteArray> loadIncrementalResultSet(qint64 baseRevision); 68 QVector<QByteArray> loadIncrementalResultSet(qint64 baseRevision);
@@ -107,6 +108,12 @@ public:
107 return mDatastore->indexLookup(property, value); 108 return mDatastore->indexLookup(property, value);
108 } 109 }
109 110
111 void readPrevious(const QByteArray &key, const std::function<void (const Sink::ApplicationDomain::ApplicationDomainType &)> &callback)
112 {
113 Q_ASSERT(mDatastore);
114 mDatastore->readPrevious(key, callback);
115 }
116
110 virtual void skip() { mSource->skip(); } 117 virtual void skip() { mSource->skip(); }
111 118
112 //Returns true for as long as a result is available 119 //Returns true for as long as a result is available