This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch fix_late_reply
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 352902552 addres review
add ffb186dba feat(gateways): iggy gateway for kafka listener (#3519)
add 28035ad0e Merge branch 'master' into fix_late_reply
No new revisions were added by this update.
Summary of changes:
.github/actions/rust/pre-merge/action.yml | 38 +
.github/config/components.yml | 10 +
.github/workflows/pr-title.yml | 1 +
.gitignore | 1 +
Cargo.lock | 70 ++
Cargo.toml | 2 +
.../configs/src/configs_impl/typed_env_provider.rs | 13 +-
gateways/README.md | 9 +
{core/bench => gateways/kafka}/Cargo.toml | 57 +-
gateways/kafka/README.md | 63 ++
gateways/kafka/docs/MANUAL_TESTING.md | 307 +++++++
gateways/kafka/docs/SCOPE.md | 138 +++
gateways/kafka/docs/TEST_SUITE.md | 66 ++
gateways/kafka/docs/kafka_api_keys_reference.md | 316 +++++++
gateways/kafka/scripts/ci-wire-fixtures.sh | 57 ++
gateways/kafka/src/error.rs | 45 +
.../steps/mod.rs => gateways/kafka/src/lib.rs | 12 +-
gateways/kafka/src/main.rs | 240 +++++
gateways/kafka/src/protocol/api.rs | 637 +++++++++++++
gateways/kafka/src/protocol/bounds_guard.rs | 906 +++++++++++++++++++
gateways/kafka/src/protocol/header.rs | 40 +
.../helpers => gateways/kafka/src/protocol}/mod.rs | 6 +-
gateways/kafka/src/protocol/responses.rs | 318 +++++++
gateways/kafka/src/server.rs | 896 +++++++++++++++++++
gateways/kafka/tests/api_handler_tests.rs | 989 +++++++++++++++++++++
gateways/kafka/tests/broker_advertise_tests.rs | 117 +++
gateways/kafka/tests/common/codec.rs | 292 ++++++
gateways/kafka/tests/common/fixtures.rs | 91 ++
.../kafka/tests/common/scope.rs | 26 +-
gateways/kafka/tests/common/server.rs | 68 ++
gateways/kafka/tests/common/tcp.rs | 258 ++++++
gateways/kafka/tests/common/wire.rs | 447 ++++++++++
.../kafka/tests/fixtures_canary_tests.rs | 36 +-
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 122 +++
gateways/kafka/tests/header_tests.rs | 282 ++++++
gateways/kafka/tests/listener_robustness_tests.rs | 624 +++++++++++++
gateways/kafka/tests/response_negative_tests.rs | 277 ++++++
gateways/kafka/tests/server_e2e_tests.rs | 451 ++++++++++
gateways/kafka/tests/server_integration_tests.rs | 129 +++
gateways/kafka/tests/version_firewall_tests.rs | 799 +++++++++++++++++
.../kafka/tools/kafka-tool}/Cargo.toml | 20 +-
gateways/kafka/tools/kafka-tool/README.md | 251 ++++++
gateways/kafka/tools/kafka-tool/src/main.rs | 864 ++++++++++++++++++
gateways/kafka/tools/kafka-tool/src/response.rs | 389 ++++++++
.../tools/kafka-tool/tests/generate_cli_tests.rs | 82 ++
scripts/ci/coverage-baseline-affected.sh | 2 +-
46 files changed, 10794 insertions(+), 70 deletions(-)
create mode 100644 gateways/README.md
copy {core/bench => gateways/kafka}/Cargo.toml (54%)
create mode 100644 gateways/kafka/README.md
create mode 100644 gateways/kafka/docs/MANUAL_TESTING.md
create mode 100644 gateways/kafka/docs/SCOPE.md
create mode 100644 gateways/kafka/docs/TEST_SUITE.md
create mode 100644 gateways/kafka/docs/kafka_api_keys_reference.md
create mode 100755 gateways/kafka/scripts/ci-wire-fixtures.sh
create mode 100644 gateways/kafka/src/error.rs
copy bdd/rust/tests/steps/mod.rs => gateways/kafka/src/lib.rs (85%)
create mode 100644 gateways/kafka/src/main.rs
create mode 100644 gateways/kafka/src/protocol/api.rs
create mode 100644 gateways/kafka/src/protocol/bounds_guard.rs
create mode 100644 gateways/kafka/src/protocol/header.rs
copy {bdd/rust/tests/helpers => gateways/kafka/src/protocol}/mod.rs (91%)
create mode 100644 gateways/kafka/src/protocol/responses.rs
create mode 100644 gateways/kafka/src/server.rs
create mode 100644 gateways/kafka/tests/api_handler_tests.rs
create mode 100644 gateways/kafka/tests/broker_advertise_tests.rs
create mode 100644 gateways/kafka/tests/common/codec.rs
create mode 100644 gateways/kafka/tests/common/fixtures.rs
copy bdd/rust/tests/stream_crud.rs => gateways/kafka/tests/common/scope.rs
(60%)
create mode 100644 gateways/kafka/tests/common/server.rs
create mode 100644 gateways/kafka/tests/common/tcp.rs
create mode 100644 gateways/kafka/tests/common/wire.rs
copy foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyObjFactory.cs =>
gateways/kafka/tests/fixtures_canary_tests.rs (51%)
create mode 100644 gateways/kafka/tests/golden_wire_fixtures_tests.rs
create mode 100644 gateways/kafka/tests/header_tests.rs
create mode 100644 gateways/kafka/tests/listener_robustness_tests.rs
create mode 100644 gateways/kafka/tests/response_negative_tests.rs
create mode 100644 gateways/kafka/tests/server_e2e_tests.rs
create mode 100644 gateways/kafka/tests/server_integration_tests.rs
create mode 100644 gateways/kafka/tests/version_firewall_tests.rs
copy {core/bench/runner => gateways/kafka/tools/kafka-tool}/Cargo.toml (73%)
create mode 100644 gateways/kafka/tools/kafka-tool/README.md
create mode 100644 gateways/kafka/tools/kafka-tool/src/main.rs
create mode 100644 gateways/kafka/tools/kafka-tool/src/response.rs
create mode 100644 gateways/kafka/tools/kafka-tool/tests/generate_cli_tests.rs
