Jeremy B
063e297e1e
Avoid usage of time.sleep ( #434 )
...
e2e python: added tooling function around `time.sleep()` that stops as soon as condition is fulfilled and will raise assert if timeout is reached
2022-07-08 10:47:18 +02:00
Jeremy B
41d4185156
Add limit batches option to start stream query ( #392 )
2022-06-20 15:09:45 +03:00
Jeremy B
a0bc1371dd
Adding "raw message" column to the result returned by CHECK STREAM query ( #394 )
...
* Adding "raw message" column to the result return by CHECK STREAM query
* Update way results of CHECK STREAM are built
* Adapting CHECK STREAM integration tests (Pulsar/Kafka) to run with new result structure
* Adding new tests covering the check stream functionality
* Uppercase constants in stream tests
* Reformat f-strings
2022-06-08 23:17:44 +02:00
Antonio Andelic
aabec99a8e
Procedure for stream configs ( #301 )
2021-11-29 08:56:10 +01:00
Antonio Andelic
e8976e0f1c
Update mgp API for Pulsar ( #298 )
2021-11-16 16:00:25 +01:00
Antonio Andelic
8606e69fd6
Add support for type in show streams ( #300 )
2021-11-16 15:58:36 +01:00
Antonio Andelic
c7b045bffc
Pulsar e2e tests ( #296 )
2021-11-16 15:58:35 +01:00
Antonio Andelic
0ebd52aac3
Support for different consumers ( #280 )
2021-11-16 15:40:27 +01:00
Antonio Andelic
bd21bc82b7
Add license to cpp/hpp/py test files ( #283 )
2021-10-26 08:53:56 +02:00
Kostas Kyrimis
10196f3d7d
Add bootstrap servers to create stream ( #274 )
2021-10-18 10:49:00 +02:00
János Benjamin Antal
09cfca35f8
Add privilege check in triggers and streams ( #200 )
2021-07-22 16:22:08 +02:00
