implement arbitrary source, stream and group names
Showing
- broker/src/asapo_broker/database/encoding.go 80 additions, 0 deletionsbroker/src/asapo_broker/database/encoding.go
- broker/src/asapo_broker/database/mongodb.go 17 additions, 8 deletionsbroker/src/asapo_broker/database/mongodb.go
- broker/src/asapo_broker/database/mongodb_streams.go 4 additions, 3 deletionsbroker/src/asapo_broker/database/mongodb_streams.go
- broker/src/asapo_broker/database/mongodb_test.go 62 additions, 4 deletionsbroker/src/asapo_broker/database/mongodb_test.go
- broker/src/asapo_broker/server/get_commands_test.go 39 additions, 11 deletionsbroker/src/asapo_broker/server/get_commands_test.go
- broker/src/asapo_broker/server/process_request.go 17 additions, 24 deletionsbroker/src/asapo_broker/server/process_request.go
- broker/src/asapo_broker/server/process_request_test.go 0 additions, 6 deletionsbroker/src/asapo_broker/server/process_request_test.go
- common/cpp/include/asapo/database/database.h 0 additions, 1 deletioncommon/cpp/include/asapo/database/database.h
- common/cpp/include/asapo/database/db_error.h 6 additions, 1 deletioncommon/cpp/include/asapo/database/db_error.h
- common/cpp/include/asapo/http_client/http_client.h 1 addition, 0 deletionscommon/cpp/include/asapo/http_client/http_client.h
- common/cpp/include/asapo/unittests/MockHttpClient.h 7 additions, 0 deletionscommon/cpp/include/asapo/unittests/MockHttpClient.h
- common/cpp/src/database/CMakeLists.txt 13 additions, 0 deletionscommon/cpp/src/database/CMakeLists.txt
- common/cpp/src/database/encoding.cpp 104 additions, 0 deletionscommon/cpp/src/database/encoding.cpp
- common/cpp/src/database/encoding.h 14 additions, 0 deletionscommon/cpp/src/database/encoding.h
- common/cpp/src/database/mongodb_client.cpp 54 additions, 22 deletionscommon/cpp/src/database/mongodb_client.cpp
- common/cpp/src/database/mongodb_client.h 5 additions, 1 deletioncommon/cpp/src/database/mongodb_client.h
- common/cpp/src/http_client/curl_http_client.cpp 13 additions, 0 deletionscommon/cpp/src/http_client/curl_http_client.cpp
- common/cpp/src/http_client/curl_http_client.h 2 additions, 0 deletionscommon/cpp/src/http_client/curl_http_client.h
- common/cpp/unittests/database/test_encoding.cpp 50 additions, 0 deletionscommon/cpp/unittests/database/test_encoding.cpp
- common/go/src/asapo_common/utils/routes.go 1 addition, 1 deletioncommon/go/src/asapo_common/utils/routes.go
Loading
Please register or sign in to comment