summaryrefslogtreecommitdiffstats
path: root/common
diff options
context:
space:
mode:
Diffstat (limited to 'common')
-rw-r--r--common/clientapi.cpp12
-rw-r--r--common/clientapi.h26
-rw-r--r--common/inspection.h2
3 files changed, 20 insertions, 20 deletions
diff --git a/common/clientapi.cpp b/common/clientapi.cpp
index f67606e..cbbfdd8 100644
--- a/common/clientapi.cpp
+++ b/common/clientapi.cpp
@@ -155,7 +155,7 @@ KAsync::Job<void> Store::remove(const DomainType &domainObject)
155 }); 155 });
156} 156}
157 157
158KAsync::Job<void> Resources::shutdown(const QByteArray &identifier) 158KAsync::Job<void> ResourceControl::shutdown(const QByteArray &identifier)
159{ 159{
160 Trace() << "shutdown " << identifier; 160 Trace() << "shutdown " << identifier;
161 auto time = QSharedPointer<QTime>::create(); 161 auto time = QSharedPointer<QTime>::create();
@@ -178,7 +178,7 @@ KAsync::Job<void> Resources::shutdown(const QByteArray &identifier)
178 .template then<void>([](){}); 178 .template then<void>([](){});
179} 179}
180 180
181KAsync::Job<void> Resources::start(const QByteArray &identifier) 181KAsync::Job<void> ResourceControl::start(const QByteArray &identifier)
182{ 182{
183 Trace() << "start " << identifier; 183 Trace() << "start " << identifier;
184 auto time = QSharedPointer<QTime>::create(); 184 auto time = QSharedPointer<QTime>::create();
@@ -221,7 +221,7 @@ KAsync::Job<void> Store::synchronize(const Sink::Query &query)
221 .template then<void>([](){}); 221 .template then<void>([](){});
222} 222}
223 223
224KAsync::Job<void> Resources::flushMessageQueue(const QByteArrayList &resourceIdentifier) 224KAsync::Job<void> ResourceControl::flushMessageQueue(const QByteArrayList &resourceIdentifier)
225{ 225{
226 Trace() << "flushMessageQueue" << resourceIdentifier; 226 Trace() << "flushMessageQueue" << resourceIdentifier;
227 return KAsync::iterate(resourceIdentifier) 227 return KAsync::iterate(resourceIdentifier)
@@ -237,7 +237,7 @@ KAsync::Job<void> Resources::flushMessageQueue(const QByteArrayList &resourceIde
237 .template then<void>([](){}); 237 .template then<void>([](){});
238} 238}
239 239
240KAsync::Job<void> Resources::flushReplayQueue(const QByteArrayList &resourceIdentifier) 240KAsync::Job<void> ResourceControl::flushReplayQueue(const QByteArrayList &resourceIdentifier)
241{ 241{
242 return flushMessageQueue(resourceIdentifier); 242 return flushMessageQueue(resourceIdentifier);
243} 243}
@@ -304,7 +304,7 @@ KAsync::Job<QList<typename DomainType::Ptr> > Store::fetch(const Sink::Query &qu
304} 304}
305 305
306template <class DomainType> 306template <class DomainType>
307KAsync::Job<void> Resources::inspect(const Inspection &inspectionCommand) 307KAsync::Job<void> ResourceControl::inspect(const Inspection &inspectionCommand)
308{ 308{
309 auto resource = inspectionCommand.resourceIdentifier; 309 auto resource = inspectionCommand.resourceIdentifier;
310 310
@@ -375,7 +375,7 @@ void Notifier::registerHandler(std::function<void(const Notification &)> handler
375 template KAsync::Job<void> Store::create<T>(const T &domainObject); \ 375 template KAsync::Job<void> Store::create<T>(const T &domainObject); \
376 template KAsync::Job<void> Store::modify<T>(const T &domainObject); \ 376 template KAsync::Job<void> Store::modify<T>(const T &domainObject); \
377 template QSharedPointer<QAbstractItemModel> Store::loadModel<T>(Query query); \ 377 template QSharedPointer<QAbstractItemModel> Store::loadModel<T>(Query query); \
378 template KAsync::Job<void> Resources::inspect<T>(const Inspection &); \ 378 template KAsync::Job<void> ResourceControl::inspect<T>(const Inspection &); \
379 template KAsync::Job<T> Store::fetchOne<T>(const Query &); \ 379 template KAsync::Job<T> Store::fetchOne<T>(const Query &); \
380 template KAsync::Job<QList<T::Ptr> > Store::fetchAll<T>(const Query &); \ 380 template KAsync::Job<QList<T::Ptr> > Store::fetchAll<T>(const Query &); \
381 template KAsync::Job<QList<T::Ptr> > Store::fetch<T>(const Query &, int); \ 381 template KAsync::Job<QList<T::Ptr> > Store::fetch<T>(const Query &, int); \
diff --git a/common/clientapi.h b/common/clientapi.h
index fb44ca2..2b49826 100644
--- a/common/clientapi.h
+++ b/common/clientapi.h
@@ -111,33 +111,33 @@ KAsync::Job<QList<typename DomainType::Ptr> > SINK_EXPORT fetch(const Sink::Quer
111 111
112}; 112};
113 113
114namespace Resources { 114namespace ResourceControl {
115 115
116template <class DomainType> 116template <class DomainType>
117KAsync::Job<void> SINK_EXPORT inspect(const Inspection &inspectionCommand); 117KAsync::Job<void> SINK_EXPORT inspect(const Inspection &inspectionCommand);
118 118
119/** 119/**
120 * Shutdown resource. 120 * Shutdown resource.
121 */ 121 */
122KAsync::Job<void> SINK_EXPORT shutdown(const QByteArray &resourceIdentifier); 122KAsync::Job<void> SINK_EXPORT shutdown(const QByteArray &resourceIdentifier);
123 123
124/** 124/**
125 * Start resource. 125 * Start resource.
126 * 126 *
127 * The resource is ready for operation once this command completes. 127 * The resource is ready for operation once this command completes.
128 * This command is only necessary if a resource was shutdown previously, 128 * This command is only necessary if a resource was shutdown previously,
129 * otherwise the resource process will automatically start as necessary. 129 * otherwise the resource process will automatically start as necessary.
130 */ 130 */
131KAsync::Job<void> SINK_EXPORT start(const QByteArray &resourceIdentifier); 131KAsync::Job<void> SINK_EXPORT start(const QByteArray &resourceIdentifier);
132 132
133/** 133/**
134 * Flushes any pending messages to disk 134 * Flushes any pending messages to disk
135 */ 135 */
136KAsync::Job<void> SINK_EXPORT flushMessageQueue(const QByteArrayList &resourceIdentifier); 136KAsync::Job<void> SINK_EXPORT flushMessageQueue(const QByteArrayList &resourceIdentifier);
137 137
138/** 138/**
139 * Flushes any pending messages that haven't been replayed to the source. 139 * Flushes any pending messages that haven't been replayed to the source.
140 */ 140 */
141KAsync::Job<void> SINK_EXPORT flushReplayQueue(const QByteArrayList &resourceIdentifier); 141KAsync::Job<void> SINK_EXPORT flushReplayQueue(const QByteArrayList &resourceIdentifier);
142 142
143} 143}
diff --git a/common/inspection.h b/common/inspection.h
index b9f6bf3..d85eab6 100644
--- a/common/inspection.h
+++ b/common/inspection.h
@@ -24,7 +24,7 @@
24#include "applicationdomaintype.h" 24#include "applicationdomaintype.h"
25 25
26namespace Sink { 26namespace Sink {
27 namespace Resources { 27 namespace ResourceControl {
28 28
29struct Inspection { 29struct Inspection {
30 static Inspection PropertyInspection(const Sink::ApplicationDomain::Entity &entity, const QByteArray &property, const QVariant &expectedValue) 30 static Inspection PropertyInspection(const Sink::ApplicationDomain::Entity &entity, const QByteArray &property, const QVariant &expectedValue)