-
- Downloads
Merge pull request #133 in ASAPO/asapo from...
Merge pull request #133 in ASAPO/asapo from feature_ASAPO-128-stream_finish_flag-for-pipeline-workers-life-circle to develop * commit 'ff3e8ec8': update StreamInfo returned by producer API implement filters for stream list update stream info content for consumers start working on stream infos, refactoring fix test implement get_current_dataset_count
No related branches found
No related tags found
Showing
- CHANGELOG.md 8 additions, 2 deletionsCHANGELOG.md
- broker/src/asapo_broker/database/mongodb.go 213 additions, 123 deletionsbroker/src/asapo_broker/database/mongodb.go
- broker/src/asapo_broker/database/mongodb_streams.go 173 additions, 28 deletionsbroker/src/asapo_broker/database/mongodb_streams.go
- broker/src/asapo_broker/database/mongodb_test.go 157 additions, 35 deletionsbroker/src/asapo_broker/database/mongodb_test.go
- broker/src/asapo_broker/database/streams_test.go 95 additions, 10 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_size.go 3 additions, 1 deletionbroker/src/asapo_broker/server/get_size.go
- broker/src/asapo_broker/server/get_streams.go 2 additions, 1 deletionbroker/src/asapo_broker/server/get_streams.go
- common/cpp/include/asapo/common/data_structs.h 8 additions, 3 deletionscommon/cpp/include/asapo/common/data_structs.h
- common/cpp/src/data_structs/data_structs.cpp 10 additions, 7 deletionscommon/cpp/src/data_structs/data_structs.cpp
- common/cpp/src/database/mongodb_client.cpp 75 additions, 31 deletionscommon/cpp/src/database/mongodb_client.cpp
- common/cpp/src/database/mongodb_client.h 2 additions, 1 deletioncommon/cpp/src/database/mongodb_client.h
- common/cpp/unittests/data_structs/test_data_structs.cpp 10 additions, 28 deletionscommon/cpp/unittests/data_structs/test_data_structs.cpp
- common/go/src/asapo_common/utils/helpers.go 16 additions, 0 deletionscommon/go/src/asapo_common/utils/helpers.go
- consumer/api/cpp/include/asapo/consumer/consumer.h 24 additions, 8 deletionsconsumer/api/cpp/include/asapo/consumer/consumer.h
- consumer/api/cpp/src/consumer_impl.cpp 62 additions, 23 deletionsconsumer/api/cpp/src/consumer_impl.cpp
- consumer/api/cpp/src/consumer_impl.h 10 additions, 2 deletionsconsumer/api/cpp/src/consumer_impl.h
- consumer/api/cpp/unittests/test_consumer_impl.cpp 25 additions, 7 deletionsconsumer/api/cpp/unittests/test_consumer_impl.cpp
- consumer/api/python/asapo_consumer.pxd 8 additions, 3 deletionsconsumer/api/python/asapo_consumer.pxd
- consumer/api/python/asapo_consumer.pyx.in 23 additions, 3 deletionsconsumer/api/python/asapo_consumer.pyx.in
Loading
Please register or sign in to comment