-
- Downloads
Merge pull request #142 in ASAPO/asapo from feature_ASAPO-134-delete-stream to develop
* commit '9bd1e471': increase timout in win tests update infiniband config update changelog add test fix deadlock in producer refactor nacks fix test consumer add request api to error message delete_stream in Python and integration tests implement delete stream in broker update versions sync stream_list every 5 seconds with database for the case stream was deleted fix test add test for fts fts - check file can be read, implement delete stream from producer
No related branches found
No related tags found
Showing
- CHANGELOG.md 11 additions, 4 deletionsCHANGELOG.md
- CMakeLists.txt 4 additions, 4 deletionsCMakeLists.txt
- CMakeModules/testing_cpp.cmake 1 addition, 0 deletionsCMakeModules/testing_cpp.cmake
- PROTOCOL-VERSIONS.md 6 additions, 4 deletionsPROTOCOL-VERSIONS.md
- VERSIONS.md 10 additions, 8 deletionsVERSIONS.md
- broker/src/asapo_broker/database/mongodb.go 122 additions, 16 deletionsbroker/src/asapo_broker/database/mongodb.go
- broker/src/asapo_broker/database/mongodb_streams.go 19 additions, 9 deletionsbroker/src/asapo_broker/database/mongodb_streams.go
- broker/src/asapo_broker/database/mongodb_test.go 41 additions, 0 deletionsbroker/src/asapo_broker/database/mongodb_test.go
- broker/src/asapo_broker/server/get_streams.go 2 additions, 0 deletionsbroker/src/asapo_broker/server/get_streams.go
- broker/src/asapo_broker/server/listroutes.go 6 additions, 0 deletionsbroker/src/asapo_broker/server/listroutes.go
- broker/src/asapo_broker/server/post_create_group_test.go 1 addition, 1 deletionbroker/src/asapo_broker/server/post_create_group_test.go
- broker/src/asapo_broker/server/post_delete_stream.go 15 additions, 0 deletionsbroker/src/asapo_broker/server/post_delete_stream.go
- broker/src/asapo_broker/server/post_op_image.go 1 addition, 0 deletionsbroker/src/asapo_broker/server/post_op_image.go
- broker/src/asapo_broker/server/process_request.go 6 additions, 2 deletionsbroker/src/asapo_broker/server/process_request.go
- broker/src/asapo_broker/server/process_request_test.go 41 additions, 18 deletionsbroker/src/asapo_broker/server/process_request_test.go
- broker/src/asapo_broker/server/request_common.go 7 additions, 3 deletionsbroker/src/asapo_broker/server/request_common.go
- common/cpp/include/asapo/common/data_structs.h 32 additions, 4 deletionscommon/cpp/include/asapo/common/data_structs.h
- common/cpp/include/asapo/common/error.h 5 additions, 0 deletionscommon/cpp/include/asapo/common/error.h
- common/cpp/include/asapo/common/internal/version.h.in 9 additions, 1 deletioncommon/cpp/include/asapo/common/internal/version.h.in
- common/cpp/include/asapo/common/networking.h 1 addition, 0 deletionscommon/cpp/include/asapo/common/networking.h
Loading
Please register or sign in to comment