This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch journal_handle
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 158959cc8 Merge branch 'master' into journal_handle
add 42a6ad72f fix(configs): support internally-tagged enums in ConfigEnv
derive macro (#2631)
add 7f6d3fed9 chore(sdk): Adds Rust example for message compression using
user_headers (#2613)
add 6b700d85b fix(sdk): acquire max_in_flight permits at network send, not
dispatch (#2625)
add 76e928a44 feat(connectors): add Prometheus metrics and stats endpoints
(#2633)
add f50967dd8 feat(integration): add core test harness library (#2632)
add 0814ee01b ci(csharp): enhance test reporting and upload results (#2638)
add eff7ae108 Merge branch 'master' into journal_handle
No new revisions were added by this update.
Summary of changes:
.github/actions/csharp-dotnet/pre-merge/action.yml | 18 +-
.github/workflows/_common.yml | 1 +
.gitignore | 1 +
Cargo.lock | 12 +-
Cargo.toml | 1 +
DEPENDENCIES.md | 4 +-
.../configs/src/configs_impl/typed_env_provider.rs | 4 +-
core/configs_derive/src/config_env.rs | 20 +-
core/connectors/runtime/Cargo.toml | 4 +-
core/connectors/runtime/README.md | 25 +
core/connectors/runtime/config.toml | 4 +
core/connectors/runtime/runtime.http | 6 +
core/connectors/runtime/src/api/config.rs | 31 +-
core/connectors/runtime/src/api/mod.rs | 22 +-
core/connectors/runtime/src/configs/runtime.rs | 1 +
core/connectors/runtime/src/context.rs | 17 +-
core/connectors/runtime/src/main.rs | 2 +
core/connectors/runtime/src/manager/sink.rs | 18 +-
core/connectors/runtime/src/manager/source.rs | 18 +-
core/connectors/runtime/src/metrics.rs | 478 ++++++++++++++++
core/connectors/runtime/src/sink.rs | 39 +-
core/connectors/runtime/src/source.rs | 26 +-
core/connectors/runtime/src/stats.rs | 129 +++++
core/integration/.gitignore | 1 +
core/integration/Cargo.toml | 5 +
core/integration/src/harness/config/client.rs | 198 +++++++
core/integration/src/harness/config/common.rs | 95 ++++
.../src/harness/config/connectors_runtime.rs | 26 +-
core/integration/src/harness/config/mcp.rs | 62 +++
.../random => src/harness/config}/mod.rs | 21 +-
core/integration/src/harness/config/resolve.rs | 270 +++++++++
core/integration/src/harness/config/server.rs | 74 +++
core/integration/src/harness/context.rs | 194 +++++++
core/integration/src/harness/error.rs | 192 +++++++
core/integration/src/harness/fixtures/mod.rs | 60 ++
.../src/harness/fixtures/postgres/container.rs | 187 +++++++
.../src/harness/fixtures/postgres/mod.rs} | 15 +-
.../src/harness/fixtures/postgres/sink.rs | 213 +++++++
.../src/harness/fixtures/postgres/source.rs | 606 ++++++++++++++++++++
.../integration/src/harness/fixtures/random.rs | 19 +-
core/integration/src/harness/fixtures/wiremock.rs | 150 +++++
core/integration/src/harness/handle/client.rs | 230 ++++++++
core/integration/src/harness/handle/common.rs | 107 ++++
.../src/harness/handle/connectors_runtime.rs | 272 +++++++++
core/integration/src/harness/handle/mcp.rs | 285 ++++++++++
.../integration/src/harness/handle/mod.rs | 18 +-
core/integration/src/harness/handle/server.rs | 582 +++++++++++++++++++
core/integration/src/harness/helpers.rs | 113 ++++
core/integration/src/harness/mod.rs | 71 +++
.../src/harness/orchestrator/builder.rs | 292 ++++++++++
.../src/harness/orchestrator/harness.rs | 614 +++++++++++++++++++++
.../integration/src/harness/orchestrator/mod.rs | 6 +-
core/integration/src/harness/port_reserver.rs | 251 +++++++++
core/integration/src/harness/seeds.rs | 145 +++++
core/integration/src/harness/traits.rs | 56 ++
core/integration/src/lib.rs | 1 +
core/integration/src/websocket_client.rs | 35 +-
core/integration/tests/config_provider/mod.rs | 157 +++++-
.../tests/connectors/{random => api}/config.toml | 11 +-
.../tests/connectors/api/connectors/.gitkeep | 0
core/integration/tests/connectors/api/endpoints.rs | 217 ++++++++
.../tests/connectors/{random => api}/mod.rs | 6 +-
core/integration/tests/connectors/mod.rs | 1 +
.../tests/server/concurrent_addition.rs | 5 +-
core/integration/tests/server/mod.rs | 5 +-
.../server/scenarios/delete_segments_scenario.rs | 21 +-
core/integration/tests/server/specific.rs | 29 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/producer_dispatcher.rs | 68 +--
core/sdk/src/clients/producer_sharding.rs | 108 ++--
core/server/Cargo.toml | 2 +-
core/server/src/http/http_server.rs | 33 +-
examples/rust/Cargo.toml | 17 +-
examples/rust/README.md | 11 +-
.../message-headers/message-compression/README.md | 282 ++++++++++
.../message-compression/consumer/main.rs | 89 +++
.../message-compression/producer/main.rs | 101 ++++
.../{ => message-type}/consumer/main.rs | 0
.../{ => message-type}/producer/main.rs | 0
examples/rust/src/shared/codec.rs | 112 ++++
examples/rust/src/shared/mod.rs | 1 +
.../Fixtures/IggyServerFixture.cs | 49 +-
82 files changed, 7442 insertions(+), 232 deletions(-)
create mode 100644 core/connectors/runtime/src/metrics.rs
create mode 100644 core/connectors/runtime/src/stats.rs
create mode 100644 core/integration/.gitignore
create mode 100644 core/integration/src/harness/config/client.rs
create mode 100644 core/integration/src/harness/config/common.rs
copy
foreign/java/buildSrc/src/main/kotlin/iggy.java-application-conventions.gradle.kts
=> core/integration/src/harness/config/connectors_runtime.rs (62%)
create mode 100644 core/integration/src/harness/config/mcp.rs
copy core/integration/{tests/connectors/random => src/harness/config}/mod.rs
(70%)
create mode 100644 core/integration/src/harness/config/resolve.rs
create mode 100644 core/integration/src/harness/config/server.rs
create mode 100644 core/integration/src/harness/context.rs
create mode 100644 core/integration/src/harness/error.rs
create mode 100644 core/integration/src/harness/fixtures/mod.rs
create mode 100644 core/integration/src/harness/fixtures/postgres/container.rs
copy core/{configs/src/lib.rs =>
integration/src/harness/fixtures/postgres/mod.rs} (67%)
create mode 100644 core/integration/src/harness/fixtures/postgres/sink.rs
create mode 100644 core/integration/src/harness/fixtures/postgres/source.rs
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/http/error/IggyHttpException.java
=> core/integration/src/harness/fixtures/random.rs (68%)
create mode 100644 core/integration/src/harness/fixtures/wiremock.rs
create mode 100644 core/integration/src/harness/handle/client.rs
create mode 100644 core/integration/src/harness/handle/common.rs
create mode 100644 core/integration/src/harness/handle/connectors_runtime.rs
create mode 100644 core/integration/src/harness/handle/mcp.rs
copy
foreign/java/buildSrc/src/main/kotlin/iggy.java-library-conventions.gradle.kts
=> core/integration/src/harness/handle/mod.rs (78%)
create mode 100644 core/integration/src/harness/handle/server.rs
create mode 100644 core/integration/src/harness/helpers.rs
create mode 100644 core/integration/src/harness/mod.rs
create mode 100644 core/integration/src/harness/orchestrator/builder.rs
create mode 100644 core/integration/src/harness/orchestrator/harness.rs
copy bdd/java/settings.gradle.kts =>
core/integration/src/harness/orchestrator/mod.rs (88%)
create mode 100644 core/integration/src/harness/port_reserver.rs
create mode 100644 core/integration/src/harness/seeds.rs
create mode 100644 core/integration/src/harness/traits.rs
copy core/integration/tests/connectors/{random => api}/config.toml (82%)
create mode 100644 core/integration/tests/connectors/api/connectors/.gitkeep
create mode 100644 core/integration/tests/connectors/api/endpoints.rs
copy core/integration/tests/connectors/{random => api}/mod.rs (88%)
create mode 100644
examples/rust/src/message-headers/message-compression/README.md
create mode 100644
examples/rust/src/message-headers/message-compression/consumer/main.rs
create mode 100644
examples/rust/src/message-headers/message-compression/producer/main.rs
rename examples/rust/src/message-headers/{ => message-type}/consumer/main.rs
(100%)
rename examples/rust/src/message-headers/{ => message-type}/producer/main.rs
(100%)
create mode 100644 examples/rust/src/shared/codec.rs
