Rename message_id to time_id. Use _id for sequential message index given by...
Rename message_id to time_id. Use _id for sequential message index given by producer and time_id for message based on arrival time.
Showing
- .gitlab-ci.yml 1 addition, 1 deletion.gitlab-ci.yml
- broker/src/asapo_broker/database/mongodb.go 7 additions, 15 deletionsbroker/src/asapo_broker/database/mongodb.go
- broker/src/asapo_broker/database/mongodb_test.go 13 additions, 13 deletionsbroker/src/asapo_broker/database/mongodb_test.go
- broker/src/asapo_broker/server/get_commands_test.go 1 addition, 1 deletionbroker/src/asapo_broker/server/get_commands_test.go
- broker/src/asapo_broker/server/get_id.go 1 addition, 1 deletionbroker/src/asapo_broker/server/get_id.go
- common/cpp/include/asapo/common/data_structs.h 1 addition, 1 deletioncommon/cpp/include/asapo/common/data_structs.h
- common/cpp/src/data_structs/data_structs.cpp 1 addition, 1 deletioncommon/cpp/src/data_structs/data_structs.cpp
- common/cpp/src/database/mongodb_client.cpp 20 additions, 20 deletionscommon/cpp/src/database/mongodb_client.cpp
- common/cpp/src/database/mongodb_client.h 3 additions, 3 deletionscommon/cpp/src/database/mongodb_client.h
- common/cpp/unittests/data_structs/test_data_structs.cpp 3 additions, 3 deletionscommon/cpp/unittests/data_structs/test_data_structs.cpp
- consumer/api/cpp/src/consumer_impl.cpp 2 additions, 2 deletionsconsumer/api/cpp/src/consumer_impl.cpp
- consumer/api/cpp/unittests/test_consumer_impl.cpp 11 additions, 11 deletionsconsumer/api/cpp/unittests/test_consumer_impl.cpp
- 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
- receiver/src/request_handler/request_handler_db_write.cpp 2 additions, 2 deletionsreceiver/src/request_handler/request_handler_db_write.cpp
- receiver/unittests/request_handler/test_request_handler_db_writer.cpp 2 additions, 2 deletions...ttests/request_handler/test_request_handler_db_writer.cpp
- tests/automatic/broker/get_last/check_linux.sh 12 additions, 12 deletionstests/automatic/broker/get_last/check_linux.sh
- tests/automatic/broker/get_next/check_linux.sh 6 additions, 6 deletionstests/automatic/broker/get_next/check_linux.sh
- tests/automatic/consumer/consumer_api/check_linux.sh 9 additions, 9 deletionstests/automatic/consumer/consumer_api/check_linux.sh
Loading
Please register or sign in to comment