|
@@ -231,216 +231,216 @@ Dataworks_publicClient::CreateConnectionOutcomeCallable Dataworks_publicClient::
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateDataServiceApiOutcome Dataworks_publicClient::createDataServiceApi(const CreateDataServiceApiRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateDagComplementOutcome Dataworks_publicClient::createDagComplement(const CreateDagComplementRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CreateDataServiceApiOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return CreateDagComplementOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return CreateDataServiceApiOutcome(CreateDataServiceApiResult(outcome.result()));
|
|
|
|
|
|
|
+ return CreateDagComplementOutcome(CreateDagComplementResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return CreateDataServiceApiOutcome(outcome.error());
|
|
|
|
|
|
|
+ return CreateDagComplementOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void Dataworks_publicClient::createDataServiceApiAsync(const CreateDataServiceApiRequest& request, const CreateDataServiceApiAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void Dataworks_publicClient::createDagComplementAsync(const CreateDagComplementRequest& request, const CreateDagComplementAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, createDataServiceApi(request), context);
|
|
|
|
|
|
|
+ handler(this, request, createDagComplement(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateDataServiceApiOutcomeCallable Dataworks_publicClient::createDataServiceApiCallable(const CreateDataServiceApiRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateDagComplementOutcomeCallable Dataworks_publicClient::createDagComplementCallable(const CreateDagComplementRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateDataServiceApiOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateDagComplementOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->createDataServiceApi(request);
|
|
|
|
|
|
|
+ return this->createDagComplement(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateFileOutcome Dataworks_publicClient::createFile(const CreateFileRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateDagTestOutcome Dataworks_publicClient::createDagTest(const CreateDagTestRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CreateFileOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return CreateDagTestOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return CreateFileOutcome(CreateFileResult(outcome.result()));
|
|
|
|
|
|
|
+ return CreateDagTestOutcome(CreateDagTestResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return CreateFileOutcome(outcome.error());
|
|
|
|
|
|
|
+ return CreateDagTestOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void Dataworks_publicClient::createFileAsync(const CreateFileRequest& request, const CreateFileAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void Dataworks_publicClient::createDagTestAsync(const CreateDagTestRequest& request, const CreateDagTestAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, createFile(request), context);
|
|
|
|
|
|
|
+ handler(this, request, createDagTest(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateFileOutcomeCallable Dataworks_publicClient::createFileCallable(const CreateFileRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateDagTestOutcomeCallable Dataworks_publicClient::createDagTestCallable(const CreateDagTestRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateFileOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateDagTestOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->createFile(request);
|
|
|
|
|
|
|
+ return this->createDagTest(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateFolderOutcome Dataworks_publicClient::createFolder(const CreateFolderRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateDataServiceApiOutcome Dataworks_publicClient::createDataServiceApi(const CreateDataServiceApiRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CreateFolderOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return CreateDataServiceApiOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return CreateFolderOutcome(CreateFolderResult(outcome.result()));
|
|
|
|
|
|
|
+ return CreateDataServiceApiOutcome(CreateDataServiceApiResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return CreateFolderOutcome(outcome.error());
|
|
|
|
|
|
|
+ return CreateDataServiceApiOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void Dataworks_publicClient::createFolderAsync(const CreateFolderRequest& request, const CreateFolderAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void Dataworks_publicClient::createDataServiceApiAsync(const CreateDataServiceApiRequest& request, const CreateDataServiceApiAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, createFolder(request), context);
|
|
|
|
|
|
|
+ handler(this, request, createDataServiceApi(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateFolderOutcomeCallable Dataworks_publicClient::createFolderCallable(const CreateFolderRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateDataServiceApiOutcomeCallable Dataworks_publicClient::createDataServiceApiCallable(const CreateDataServiceApiRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateFolderOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateDataServiceApiOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->createFolder(request);
|
|
|
|
|
|
|
+ return this->createDataServiceApi(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateMetaCategoryOutcome Dataworks_publicClient::createMetaCategory(const CreateMetaCategoryRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateFileOutcome Dataworks_publicClient::createFile(const CreateFileRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CreateMetaCategoryOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return CreateFileOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return CreateMetaCategoryOutcome(CreateMetaCategoryResult(outcome.result()));
|
|
|
|
|
|
|
+ return CreateFileOutcome(CreateFileResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return CreateMetaCategoryOutcome(outcome.error());
|
|
|
|
|
|
|
+ return CreateFileOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void Dataworks_publicClient::createMetaCategoryAsync(const CreateMetaCategoryRequest& request, const CreateMetaCategoryAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void Dataworks_publicClient::createFileAsync(const CreateFileRequest& request, const CreateFileAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, createMetaCategory(request), context);
|
|
|
|
|
|
|
+ handler(this, request, createFile(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateMetaCategoryOutcomeCallable Dataworks_publicClient::createMetaCategoryCallable(const CreateMetaCategoryRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateFileOutcomeCallable Dataworks_publicClient::createFileCallable(const CreateFileRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateMetaCategoryOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateFileOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->createMetaCategory(request);
|
|
|
|
|
|
|
+ return this->createFile(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateNodeComplementOutcome Dataworks_publicClient::createNodeComplement(const CreateNodeComplementRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateFolderOutcome Dataworks_publicClient::createFolder(const CreateFolderRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CreateNodeComplementOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return CreateFolderOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return CreateNodeComplementOutcome(CreateNodeComplementResult(outcome.result()));
|
|
|
|
|
|
|
+ return CreateFolderOutcome(CreateFolderResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return CreateNodeComplementOutcome(outcome.error());
|
|
|
|
|
|
|
+ return CreateFolderOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void Dataworks_publicClient::createNodeComplementAsync(const CreateNodeComplementRequest& request, const CreateNodeComplementAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void Dataworks_publicClient::createFolderAsync(const CreateFolderRequest& request, const CreateFolderAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, createNodeComplement(request), context);
|
|
|
|
|
|
|
+ handler(this, request, createFolder(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateNodeComplementOutcomeCallable Dataworks_publicClient::createNodeComplementCallable(const CreateNodeComplementRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateFolderOutcomeCallable Dataworks_publicClient::createFolderCallable(const CreateFolderRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateNodeComplementOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateFolderOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->createNodeComplement(request);
|
|
|
|
|
|
|
+ return this->createFolder(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateNodeTestOutcome Dataworks_publicClient::createNodeTest(const CreateNodeTestRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateMetaCategoryOutcome Dataworks_publicClient::createMetaCategory(const CreateMetaCategoryRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CreateNodeTestOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return CreateMetaCategoryOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return CreateNodeTestOutcome(CreateNodeTestResult(outcome.result()));
|
|
|
|
|
|
|
+ return CreateMetaCategoryOutcome(CreateMetaCategoryResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return CreateNodeTestOutcome(outcome.error());
|
|
|
|
|
|
|
+ return CreateMetaCategoryOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void Dataworks_publicClient::createNodeTestAsync(const CreateNodeTestRequest& request, const CreateNodeTestAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void Dataworks_publicClient::createMetaCategoryAsync(const CreateMetaCategoryRequest& request, const CreateMetaCategoryAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, createNodeTest(request), context);
|
|
|
|
|
|
|
+ handler(this, request, createMetaCategory(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-Dataworks_publicClient::CreateNodeTestOutcomeCallable Dataworks_publicClient::createNodeTestCallable(const CreateNodeTestRequest &request) const
|
|
|
|
|
|
|
+Dataworks_publicClient::CreateMetaCategoryOutcomeCallable Dataworks_publicClient::createMetaCategoryCallable(const CreateMetaCategoryRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateNodeTestOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateMetaCategoryOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->createNodeTest(request);
|
|
|
|
|
|
|
+ return this->createMetaCategory(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|