This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch experiment
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 0397790bd Merge branch 'master' into experiment
add d0cb3d44a test(server): add API tests for message retrieval (#2537)
add c9a2eb80f feat(python): add AsyncIterator interface to IggyConsumer
(#2552)
add 1fb20b62a fix(server): broadcast PAT events from HTTP handlers to all
shards (#2589)
add 3dcdda940 chore(integration): remove streaming tests superseded by
API-level coverage (#2591)
new d06bc8d6c Merge branch 'master' into experiment
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
core/integration/tests/mod.rs | 1 -
core/integration/tests/server/cg.rs | 10 +-
core/integration/tests/server/general.rs | 3 +-
core/integration/tests/server/message_retrieval.rs | 152 +++++++
core/integration/tests/server/mod.rs | 8 +-
.../scenarios/cross_protocol_pat_scenario.rs | 233 ++++++++++
core/integration/tests/server/scenarios/mod.rs | 4 +
.../tests/server/scenarios/offset_scenario.rs | 467 +++++++++++++++++++++
.../scenarios/snapshot_scenario.rs} | 44 +-
.../tests/server/scenarios/timestamp_scenario.rs | 449 ++++++++++++++++++++
core/integration/tests/server/specific.rs | 23 +-
core/integration/tests/streaming/common/mod.rs | 19 -
.../tests/streaming/common/test_setup.rs | 52 ---
core/integration/tests/streaming/get_by_offset.rs | 396 -----------------
.../tests/streaming/get_by_timestamp.rs | 372 ----------------
core/integration/tests/streaming/mod.rs | 132 ------
core/server/src/http/personal_access_tokens.rs | 34 +-
foreign/python/Cargo.toml | 1 +
foreign/python/apache_iggy.pyi | 23 +-
foreign/python/src/client.rs | 28 +-
foreign/python/src/consumer.rs | 29 +-
foreign/python/src/iterator.rs | 59 +++
foreign/python/src/lib.rs | 3 +
foreign/python/src/receive_message.rs | 15 +-
foreign/python/tests/test_iggy_sdk.py | 47 ++-
25 files changed, 1565 insertions(+), 1039 deletions(-)
create mode 100644 core/integration/tests/server/message_retrieval.rs
create mode 100644
core/integration/tests/server/scenarios/cross_protocol_pat_scenario.rs
create mode 100644 core/integration/tests/server/scenarios/offset_scenario.rs
rename core/integration/tests/{streaming/snapshot.rs =>
server/scenarios/snapshot_scenario.rs} (56%)
create mode 100644
core/integration/tests/server/scenarios/timestamp_scenario.rs
delete mode 100644 core/integration/tests/streaming/common/mod.rs
delete mode 100644 core/integration/tests/streaming/common/test_setup.rs
delete mode 100644 core/integration/tests/streaming/get_by_offset.rs
delete mode 100644 core/integration/tests/streaming/get_by_timestamp.rs
delete mode 100644 core/integration/tests/streaming/mod.rs
create mode 100644 foreign/python/src/iterator.rs
