-
- Downloads
Merge pull request #97 in ASAPO/asapo from feature_ASAPO-111-acks to develop
* commit 'bee88c9b': fix test producer retrieves stream info start providing last id via producer fix using non-positive ids refactor, add integration tests refactor, implement last_ack_id return nacks update hasicorp pack to latest versions implement ack function started working at acks refactor create position pointer if not exist on each get_next request
No related branches found
No related tags found
Showing
- CHANGELOG.md 11 additions, 4 deletionsCHANGELOG.md
- broker/src/asapo_broker/database/mongodb.go 172 additions, 38 deletionsbroker/src/asapo_broker/database/mongodb.go
- broker/src/asapo_broker/database/mongodb_test.go 131 additions, 4 deletionsbroker/src/asapo_broker/database/mongodb_test.go
- broker/src/asapo_broker/server/get_commands_test.go 62 additions, 0 deletionsbroker/src/asapo_broker/server/get_commands_test.go
- broker/src/asapo_broker/server/get_id_test.go 0 additions, 48 deletionsbroker/src/asapo_broker/server/get_id_test.go
- broker/src/asapo_broker/server/get_last_test.go 0 additions, 42 deletionsbroker/src/asapo_broker/server/get_last_test.go
- broker/src/asapo_broker/server/get_lastack.go 9 additions, 0 deletionsbroker/src/asapo_broker/server/get_lastack.go
- broker/src/asapo_broker/server/get_meta_test.go 0 additions, 42 deletionsbroker/src/asapo_broker/server/get_meta_test.go
- broker/src/asapo_broker/server/get_nacks.go 29 additions, 0 deletionsbroker/src/asapo_broker/server/get_nacks.go
- broker/src/asapo_broker/server/get_next_test.go 0 additions, 42 deletionsbroker/src/asapo_broker/server/get_next_test.go
- broker/src/asapo_broker/server/get_substreams_test.go 0 additions, 41 deletionsbroker/src/asapo_broker/server/get_substreams_test.go
- broker/src/asapo_broker/server/listroutes.go 18 additions, 0 deletionsbroker/src/asapo_broker/server/listroutes.go
- broker/src/asapo_broker/server/post_op_image.go 36 additions, 0 deletionsbroker/src/asapo_broker/server/post_op_image.go
- broker/src/asapo_broker/server/post_op_image_test.go 11 additions, 12 deletionsbroker/src/asapo_broker/server/post_op_image_test.go
- common/cpp/include/common/data_structs.h 9 additions, 1 deletioncommon/cpp/include/common/data_structs.h
- common/cpp/include/common/networking.h 1 addition, 0 deletionscommon/cpp/include/common/networking.h
- common/cpp/include/database/database.h 1 addition, 1 deletioncommon/cpp/include/database/database.h
- common/cpp/include/request/request_pool.h 1 addition, 1 deletioncommon/cpp/include/request/request_pool.h
- common/cpp/include/unittests/MockDatabase.h 9 additions, 1 deletioncommon/cpp/include/unittests/MockDatabase.h
- common/cpp/src/data_structs/data_structs.cpp 14 additions, 0 deletionscommon/cpp/src/data_structs/data_structs.cpp
Loading
Please register or sign in to comment