Skip to content

ipgallery.common.cpp / Microservice

Go to a project
Commit 85220c52 by amir
Options

schema anf iml

parent e46d9376
Inline Side-by-side
Showing with 264 additions and 104 deletions
.idea/Microservice.iml
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<module type="CPP_MODULE" version="4"> <module classpath="CMake" type="CPP_MODULE" version="4" />
<component name="NewModuleRootManager"> \ No newline at end of file
<content url="file://$MODULE_DIR$/../3party/mongoose/mongoose.c">
<sourceFolder url="file://$MODULE_DIR$/../3party/mongoose/mongoose.c" isTestSource="false" />
</content>
<content url="file://$MODULE_DIR$">
<sourceFolder url="file://$MODULE_DIR$/src/Microservice_App.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/common/Microservice_MsgQContext.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/common/Microservice_PubSubContext.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/common/Microservice_RestResponse.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_MonitorHandler.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_RestHandler.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_MsgQHandler.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_RestHandler.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_MonitorHandler.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_RMQHandler.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_PubSubHandler.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_Reactor.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_RMQHandler.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/handlers/Microservice_Reactor.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservices_ILoggerLog4cppImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IResponseRMQImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IRequestRMQImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/MSIMetricsFactoryStdImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_ICacheClientRedisImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IResponseRestImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/MSIMetricsFactoryDropwisardImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/MSIMetricsFactoryStdImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IMsgArchiverCerealImpls.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IRequestRMQImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_ICacheClientRedisImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IConfigurationConfigPropImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/clients/MSICommandClientRMQImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/clients/MSICommandClientHttpImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/clients/MSIPubSubClientImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/clients/MSZMQClientImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/clients/MSICommandClientHttpImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/clients/MSICommandClientRMQImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/clients/MSIPubSubClientImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/clients/MSZMQClientImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IResponseRestImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/MSIMetricsFactoryDropwisardImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IConfigurationConfigPropImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservices_ILoggerLog4cppImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IRequestRestImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IResponseRMQImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/servers/Microservice_IMsgQueueServerZmqImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/servers/Microservice_IRestServerRMQImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/servers/Microservice_IMsgQueueServerZmqImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/servers/Microservice_IRestServerMongooseImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/servers/Microservice_IRestServerMongooseImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/servers/Microservice_IRestServerRMQImpl.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/impl/Microservice_IRequestRestImpl.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/Microservice_Client.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/Microservice_Client.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/Microservice_App.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/utils/ClientFactory.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/utils/ClientFactory.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/utils/ServerFactory.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/utils/ServerFactory.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/utils/ScheduledTimer.h" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/utils/ScheduledTimer.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/CMakeLists.txt" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/test/Microservice_ZMQTest.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/test/Microservice_Test.cpp" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/test/Microservice_ClientTest.cpp" isTestSource="false" />
</content>
<orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="module-library">
<library name="Header Search Paths">
<CLASSES>
<root url="file:///usr/include" />
<root url="file:///usr/lib/gcc/x86_64-linux-gnu/4.9/include" />
<root url="file:///usr/lib/gcc/x86_64-linux-gnu/4.9/include-fixed" />
<root url="file:///usr/local/include" />
<root url="file://$MODULE_DIR$/../3party/rapidjson-cereal-1.2.1" />
<root url="file://$MODULE_DIR$/../3party/cppmetrics-0.1.1-Linux/include" />
<root url="file://$MODULE_DIR$/../3party/cpprest/Release/include" />
<root url="file://$MODULE_DIR$/../3party/cereal-1.2.1/include" />
<root url="file://$MODULE_DIR$/../3party/rabbitmq" />
<root url="file://$MODULE_DIR$/../3party/mongoose" />
<root url="file://$MODULE_DIR$/../internals/include/Rabbitmq" />
</CLASSES>
<SOURCES>
<root url="file:///usr/include" />
<root url="file:///usr/lib/gcc/x86_64-linux-gnu/4.9/include" />
<root url="file:///usr/lib/gcc/x86_64-linux-gnu/4.9/include-fixed" />
<root url="file:///usr/local/include" />
<root url="file://$MODULE_DIR$/../3party/rapidjson-cereal-1.2.1" />
<root url="file://$MODULE_DIR$/../3party/cppmetrics-0.1.1-Linux/include" />
<root url="file://$MODULE_DIR$/../3party/cpprest/Release/include" />
<root url="file://$MODULE_DIR$/../3party/cereal-1.2.1/include" />
<root url="file://$MODULE_DIR$/../3party/rabbitmq" />
<root url="file://$MODULE_DIR$/../3party/mongoose" />
<root url="file://$MODULE_DIR$/../internals/include/Rabbitmq" />
</SOURCES>
<excluded>
<root url="file://$MODULE_DIR$/../3party/mongoose/mongoose.c" />
</excluded>
</library>
</orderEntry>
</component>
</module>
\ No newline at end of file
schema/RestMsg_generated.h 0 → 100644
// automatically generated by the FlatBuffers compiler, do not modify
#ifndef FLATBUFFERS_GENERATED_RESTMSG_COMMON_CONTEXT_H_
#define FLATBUFFERS_GENERATED_RESTMSG_COMMON_CONTEXT_H_
#include "flatbuffers/flatbuffers.h"
namespace common {
namespace context {
struct RestMsg;
enum CrudMethod {
CrudMethod_Create = 0,
CrudMethod_Read = 1,
CrudMethod_Update = 2,
CrudMethod_Delete = 3,
CrudMethod_MIN = CrudMethod_Create,
CrudMethod_MAX = CrudMethod_Delete
};
inline const char **EnumNamesCrudMethod() {
static const char *names[] = {
"Create",
"Read",
"Update",
"Delete",
nullptr
};
return names;
}
inline const char *EnumNameCrudMethod(CrudMethod e) {
const size_t index = static_cast<int>(e);
return EnumNamesCrudMethod()[index];
}
struct RestMsg FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
enum {
VT_RCID = 4,
VT_SOURCE = 6,
VT_CRUDMETHOD = 8,
VT_URL = 10,
VT_QUERYSTRING = 12,
VT_CONTENT = 14
};
uint64_t rcid() const {
return GetField<uint64_t>(VT_RCID, 0);
}
const flatbuffers::String *source() const {
return GetPointer<const flatbuffers::String *>(VT_SOURCE);
}
CrudMethod crudMethod() const {
return static_cast<CrudMethod>(GetField<int8_t>(VT_CRUDMETHOD, 1));
}
const flatbuffers::String *url() const {
return GetPointer<const flatbuffers::String *>(VT_URL);
}
const flatbuffers::String *queryString() const {
return GetPointer<const flatbuffers::String *>(VT_QUERYSTRING);
}
const flatbuffers::String *content() const {
return GetPointer<const flatbuffers::String *>(VT_CONTENT);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<uint64_t>(verifier, VT_RCID) &&
VerifyField<flatbuffers::uoffset_t>(verifier, VT_SOURCE) &&
verifier.Verify(source()) &&
VerifyField<int8_t>(verifier, VT_CRUDMETHOD) &&
VerifyField<flatbuffers::uoffset_t>(verifier, VT_URL) &&
verifier.Verify(url()) &&
VerifyField<flatbuffers::uoffset_t>(verifier, VT_QUERYSTRING) &&
verifier.Verify(queryString()) &&
VerifyField<flatbuffers::uoffset_t>(verifier, VT_CONTENT) &&
verifier.Verify(content()) &&
verifier.EndTable();
}
};
struct RestMsgBuilder {
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_rcid(uint64_t rcid) {
fbb_.AddElement<uint64_t>(RestMsg::VT_RCID, rcid, 0);
}
void add_source(flatbuffers::Offset<flatbuffers::String> source) {
fbb_.AddOffset(RestMsg::VT_SOURCE, source);
}
void add_crudMethod(CrudMethod crudMethod) {
fbb_.AddElement<int8_t>(RestMsg::VT_CRUDMETHOD, static_cast<int8_t>(crudMethod), 1);
}
void add_url(flatbuffers::Offset<flatbuffers::String> url) {
fbb_.AddOffset(RestMsg::VT_URL, url);
}
void add_queryString(flatbuffers::Offset<flatbuffers::String> queryString) {
fbb_.AddOffset(RestMsg::VT_QUERYSTRING, queryString);
}
void add_content(flatbuffers::Offset<flatbuffers::String> content) {
fbb_.AddOffset(RestMsg::VT_CONTENT, content);
}
RestMsgBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
RestMsgBuilder &operator=(const RestMsgBuilder &);
flatbuffers::Offset<RestMsg> Finish() {
const auto end = fbb_.EndTable(start_, 6);
auto o = flatbuffers::Offset<RestMsg>(end);
return o;
}
};
inline flatbuffers::Offset<RestMsg> CreateRestMsg(
flatbuffers::FlatBufferBuilder &_fbb,
uint64_t rcid = 0,
flatbuffers::Offset<flatbuffers::String> source = 0,
CrudMethod crudMethod = CrudMethod_Read,
flatbuffers::Offset<flatbuffers::String> url = 0,
flatbuffers::Offset<flatbuffers::String> queryString = 0,
flatbuffers::Offset<flatbuffers::String> content = 0) {
RestMsgBuilder builder_(_fbb);
builder_.add_rcid(rcid);
builder_.add_content(content);
builder_.add_queryString(queryString);
builder_.add_url(url);
builder_.add_source(source);
builder_.add_crudMethod(crudMethod);
return builder_.Finish();
}
inline flatbuffers::Offset<RestMsg> CreateRestMsgDirect(
flatbuffers::FlatBufferBuilder &_fbb,
uint64_t rcid = 0,
const char *source = nullptr,
CrudMethod crudMethod = CrudMethod_Read,
const char *url = nullptr,
const char *queryString = nullptr,
const char *content = nullptr) {
return common::context::CreateRestMsg(
_fbb,
rcid,
source ? _fbb.CreateString(source) : 0,
crudMethod,
url ? _fbb.CreateString(url) : 0,
queryString ? _fbb.CreateString(queryString) : 0,
content ? _fbb.CreateString(content) : 0);
}
inline const common::context::RestMsg *GetRestMsg(const void *buf) {
return flatbuffers::GetRoot<common::context::RestMsg>(buf);
}
inline bool VerifyRestMsgBuffer(
flatbuffers::Verifier &verifier) {
return verifier.VerifyBuffer<common::context::RestMsg>(nullptr);
}
inline void FinishRestMsgBuffer(
flatbuffers::FlatBufferBuilder &fbb,
flatbuffers::Offset<common::context::RestMsg> root) {
fbb.Finish(root);
}
} // namespace context
} // namespace common
#endif // FLATBUFFERS_GENERATED_RESTMSG_COMMON_CONTEXT_H_
schema/RestResponse_generated.h 0 → 100644
// automatically generated by the FlatBuffers compiler, do not modify
#ifndef FLATBUFFERS_GENERATED_RESTRESPONSE_COMMON_CONTEXT_H_
#define FLATBUFFERS_GENERATED_RESTRESPONSE_COMMON_CONTEXT_H_
#include "flatbuffers/flatbuffers.h"
namespace common {
namespace context {
struct RestResponse;
struct RestResponse FLATBUFFERS_FINAL_CLASS : private flatbuffers::Table {
enum {
VT_RCID = 4,
VT_RESPONSE = 6
};
uint64_t rcid() const {
return GetField<uint64_t>(VT_RCID, 0);
}
const flatbuffers::String *response() const {
return GetPointer<const flatbuffers::String *>(VT_RESPONSE);
}
bool Verify(flatbuffers::Verifier &verifier) const {
return VerifyTableStart(verifier) &&
VerifyField<uint64_t>(verifier, VT_RCID) &&
VerifyField<flatbuffers::uoffset_t>(verifier, VT_RESPONSE) &&
verifier.Verify(response()) &&
verifier.EndTable();
}
};
struct RestResponseBuilder {
flatbuffers::FlatBufferBuilder &fbb_;
flatbuffers::uoffset_t start_;
void add_rcid(uint64_t rcid) {
fbb_.AddElement<uint64_t>(RestResponse::VT_RCID, rcid, 0);
}
void add_response(flatbuffers::Offset<flatbuffers::String> response) {
fbb_.AddOffset(RestResponse::VT_RESPONSE, response);
}
RestResponseBuilder(flatbuffers::FlatBufferBuilder &_fbb)
: fbb_(_fbb) {
start_ = fbb_.StartTable();
}
RestResponseBuilder &operator=(const RestResponseBuilder &);
flatbuffers::Offset<RestResponse> Finish() {
const auto end = fbb_.EndTable(start_, 2);
auto o = flatbuffers::Offset<RestResponse>(end);
return o;
}
};
inline flatbuffers::Offset<RestResponse> CreateRestResponse(
flatbuffers::FlatBufferBuilder &_fbb,
uint64_t rcid = 0,
flatbuffers::Offset<flatbuffers::String> response = 0) {
RestResponseBuilder builder_(_fbb);
builder_.add_rcid(rcid);
builder_.add_response(response);
return builder_.Finish();
}
inline flatbuffers::Offset<RestResponse> CreateRestResponseDirect(
flatbuffers::FlatBufferBuilder &_fbb,
uint64_t rcid = 0,
const char *response = nullptr) {
return common::context::CreateRestResponse(
_fbb,
rcid,
response ? _fbb.CreateString(response) : 0);
}
inline const common::context::RestResponse *GetRestResponse(const void *buf) {
return flatbuffers::GetRoot<common::context::RestResponse>(buf);
}
inline bool VerifyRestResponseBuffer(
flatbuffers::Verifier &verifier) {
return verifier.VerifyBuffer<common::context::RestResponse>(nullptr);
}
inline void FinishRestResponseBuffer(
flatbuffers::FlatBufferBuilder &fbb,
flatbuffers::Offset<common::context::RestResponse> root) {
fbb.Finish(root);
}
} // namespace context
} // namespace common
#endif // FLATBUFFERS_GENERATED_RESTRESPONSE_COMMON_CONTEXT_H_
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment