-
- Downloads
Merge branch 'refactor_streams' into 'develop'
Add all streams in one collection See merge request !245
No related branches found
No related tags found
Showing
- broker/src/asapo_broker/database/encoding.go 4 additions, 6 deletionsbroker/src/asapo_broker/database/encoding.go
- broker/src/asapo_broker/database/encoding_test.go 6 additions, 7 deletionsbroker/src/asapo_broker/database/encoding_test.go
- broker/src/asapo_broker/database/mongodb.go 163 additions, 94 deletionsbroker/src/asapo_broker/database/mongodb.go
- broker/src/asapo_broker/database/mongodb_insert.go 29 additions, 11 deletionsbroker/src/asapo_broker/database/mongodb_insert.go
- broker/src/asapo_broker/database/mongodb_streams.go 7 additions, 10 deletionsbroker/src/asapo_broker/database/mongodb_streams.go
- broker/src/asapo_broker/database/mongodb_test.go 353 additions, 337 deletionsbroker/src/asapo_broker/database/mongodb_test.go
- broker/src/asapo_broker/database/streams_test.go 33 additions, 33 deletionsbroker/src/asapo_broker/database/streams_test.go
- broker/src/asapo_broker/server/get_commands_test.go 3 additions, 3 deletionsbroker/src/asapo_broker/server/get_commands_test.go
- broker/src/asapo_broker/server/get_id.go 2 additions, 2 deletionsbroker/src/asapo_broker/server/get_id.go
- broker/src/asapo_broker/server/get_next.go 2 additions, 2 deletionsbroker/src/asapo_broker/server/get_next.go
- broker/src/asapo_broker/server/process_request_test.go 5 additions, 5 deletionsbroker/src/asapo_broker/server/process_request_test.go
- examples/consumer/getnext_python/check_linux.sh 1 addition, 1 deletionexamples/consumer/getnext_python/check_linux.sh
- examples/pipeline/in_to_out/check_linux.sh 3 additions, 3 deletionsexamples/pipeline/in_to_out/check_linux.sh
- examples/pipeline/in_to_out_python/check_linux.sh 3 additions, 3 deletionsexamples/pipeline/in_to_out_python/check_linux.sh
- tests/automatic/broker/get_last/check_linux.sh 11 additions, 11 deletionstests/automatic/broker/get_last/check_linux.sh
- tests/automatic/broker/get_next/check_linux.sh 4 additions, 4 deletionstests/automatic/broker/get_next/check_linux.sh
- tests/automatic/consumer/consumer_api/check_linux.sh 12 additions, 9 deletionstests/automatic/consumer/consumer_api/check_linux.sh
- tests/automatic/consumer/consumer_api_python/check_linux.sh 13 additions, 11 deletionstests/automatic/consumer/consumer_api_python/check_linux.sh
- tests/automatic/consumer/next_multithread_broker/check_linux.sh 1 addition, 1 deletion...automatic/consumer/next_multithread_broker/check_linux.sh
- tests/automatic/producer/aai/check_linux.sh 3 additions, 2 deletionstests/automatic/producer/aai/check_linux.sh
Loading
Please register or sign in to comment