first draft of persisted streams
Showing
- broker/src/asapo_broker/database/mongodb.go 32 additions, 0 deletionsbroker/src/asapo_broker/database/mongodb.go
- broker/src/asapo_broker/server/listroutes.go 6 additions, 0 deletionsbroker/src/asapo_broker/server/listroutes.go
- broker/src/asapo_broker/server/post_persist_stream.go 11 additions, 0 deletionsbroker/src/asapo_broker/server/post_persist_stream.go
- broker/src/asapo_broker/server/server.go 12 additions, 2 deletionsbroker/src/asapo_broker/server/server.go
- common/cpp/include/asapo/common/networking.h 2 additions, 0 deletionscommon/cpp/include/asapo/common/networking.h
- common/cpp/include/asapo/database/database.h 2 additions, 0 deletionscommon/cpp/include/asapo/database/database.h
- common/cpp/include/asapo/unittests/MockDatabase.h 12 additions, 0 deletionscommon/cpp/include/asapo/unittests/MockDatabase.h
- common/cpp/src/database/mongodb_client.cpp 53 additions, 0 deletionscommon/cpp/src/database/mongodb_client.cpp
- common/cpp/src/database/mongodb_client.h 3 additions, 0 deletionscommon/cpp/src/database/mongodb_client.h
- consumer/api/c/include/asapo/consumer_c.h 3 additions, 0 deletionsconsumer/api/c/include/asapo/consumer_c.h
- consumer/api/cpp/include/asapo/consumer/consumer.h 6 additions, 0 deletionsconsumer/api/cpp/include/asapo/consumer/consumer.h
- consumer/api/cpp/src/consumer_c_glue.cpp 12 additions, 0 deletionsconsumer/api/cpp/src/consumer_c_glue.cpp
- consumer/api/cpp/src/consumer_impl.cpp 9 additions, 0 deletionsconsumer/api/cpp/src/consumer_impl.cpp
- consumer/api/cpp/src/consumer_impl.h 1 addition, 0 deletionsconsumer/api/cpp/src/consumer_impl.h
- consumer/api/python/asapo_consumer.pxd 1 addition, 0 deletionsconsumer/api/python/asapo_consumer.pxd
- consumer/api/python/asapo_consumer.pyx.in 16 additions, 0 deletionsconsumer/api/python/asapo_consumer.pyx.in
- deploy/asapo_helm_chart/asapo/configs/asapo-receiver.json 1 addition, 0 deletionsdeploy/asapo_helm_chart/asapo/configs/asapo-receiver.json
- deploy/asapo_services/scripts/receiver.json.tpl 1 addition, 0 deletionsdeploy/asapo_services/scripts/receiver.json.tpl
- producer/api/c/include/asapo/producer_c.h 1 addition, 0 deletionsproducer/api/c/include/asapo/producer_c.h
- producer/api/cpp/include/asapo/producer/producer.h 8 additions, 1 deletionproducer/api/cpp/include/asapo/producer/producer.h
Loading
Please register or sign in to comment