[c++] Events broker
The broker polls restful API for events and dispatches them to gRPC streams.
Showing
- cpp/.clang-format 33 additions, 0 deletionscpp/.clang-format
- cpp/proto 1 addition, 1 deletioncpp/proto
- cpp/src/CMakeLists.txt 5 additions, 2 deletionscpp/src/CMakeLists.txt
- cpp/src/csandbox.cc 48 additions, 13 deletionscpp/src/csandbox.cc
- cpp/src/vereign/container/bounded_queue.hh 139 additions, 0 deletionscpp/src/vereign/container/bounded_queue.hh
- cpp/src/vereign/event/broker.cc 266 additions, 0 deletionscpp/src/vereign/event/broker.cc
- cpp/src/vereign/event/broker.hh 131 additions, 0 deletionscpp/src/vereign/event/broker.hh
- cpp/src/vereign/grpc/event_api.hh 86 additions, 0 deletionscpp/src/vereign/grpc/event_api.hh
- cpp/src/vereign/grpc/server.cc 25 additions, 1 deletioncpp/src/vereign/grpc/server.cc
- cpp/src/vereign/grpc/service_registry.hh 12 additions, 0 deletionscpp/src/vereign/grpc/service_registry.hh
- cpp/src/vereign/identity/provider.cc 4 additions, 0 deletionscpp/src/vereign/identity/provider.cc
- cpp/src/vereign/identity/provider.hh 2 additions, 0 deletionscpp/src/vereign/identity/provider.hh
- cpp/src/vereign/restapi/client.cc 14 additions, 14 deletionscpp/src/vereign/restapi/client.cc
- cpp/src/vereign/restapi/client.hh 8 additions, 10 deletionscpp/src/vereign/restapi/client.hh
- cpp/src/vereign/restapi/client_session.hh 145 additions, 17 deletionscpp/src/vereign/restapi/client_session.hh
- cpp/src/vereign/restapi/detail/post_task.hh 3 additions, 3 deletionscpp/src/vereign/restapi/detail/post_task.hh
- cpp/src/vereign/service/identity_service.cc 3 additions, 3 deletionscpp/src/vereign/service/identity_service.cc
- cpp/src/vereign/sync/channel.hh 43 additions, 48 deletionscpp/src/vereign/sync/channel.hh
- cpp/tests/vereign/CMakeLists.txt 2 additions, 0 deletionscpp/tests/vereign/CMakeLists.txt
- cpp/tests/vereign/container/bounded_queue_test.cc 81 additions, 0 deletionscpp/tests/vereign/container/bounded_queue_test.cc
Loading
Please register or sign in to comment