summaryrefslogtreecommitdiffstats
path: root/common/pipeline.h
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-05-28 00:24:53 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-05-28 00:24:53 +0200
commite9c75177590d8546ebd9425f16c4269a9c92f517 (patch)
tree8a953631e467d9df50657e22bd90954b7b71c990 /common/pipeline.h
parent8f01eb530262d1442fc4fa0782a41e052412d43b (diff)
downloadsink-e9c75177590d8546ebd9425f16c4269a9c92f517.tar.gz
sink-e9c75177590d8546ebd9425f16c4269a9c92f517.zip
Refactored the generic resource to use separate classes for
changereplay and synchronization. This cleans up the API and avoids the excessive passing around of transactions. It also provides more flexibility in eventually using different synchronization strategies for different resources.
Diffstat (limited to 'common/pipeline.h')
-rw-r--r--common/pipeline.h3
1 files changed, 1 insertions, 2 deletions
diff --git a/common/pipeline.h b/common/pipeline.h
index c65cbfd..2ca87a4 100644
--- a/common/pipeline.h
+++ b/common/pipeline.h
@@ -46,13 +46,12 @@ public:
46 46
47 Storage &storage() const; 47 Storage &storage() const;
48 48
49 void setResourceType(const QByteArray &resourceType);
49 void setPreprocessors(const QString &entityType, const QVector<Preprocessor *> &preprocessors); 50 void setPreprocessors(const QString &entityType, const QVector<Preprocessor *> &preprocessors);
50 void startTransaction(); 51 void startTransaction();
51 void commit(); 52 void commit();
52 Storage::Transaction &transaction(); 53 Storage::Transaction &transaction();
53 54
54 void setAdaptorFactory(const QString &entityType, DomainTypeAdaptorFactoryInterface::Ptr factory);
55
56 KAsync::Job<qint64> newEntity(void const *command, size_t size); 55 KAsync::Job<qint64> newEntity(void const *command, size_t size);
57 KAsync::Job<qint64> modifiedEntity(void const *command, size_t size); 56 KAsync::Job<qint64> modifiedEntity(void const *command, size_t size);
58 KAsync::Job<qint64> deletedEntity(void const *command, size_t size); 57 KAsync::Job<qint64> deletedEntity(void const *command, size_t size);