This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch dependabot/uv/bdd/python/mako-1.3.11
in repository https://gitbox.apache.org/repos/asf/iggy.git
from f81e4ebe4 Merge branch 'master' into
dependabot/uv/bdd/python/mako-1.3.11
add 7de9d093f chore(deps): bump python-dotenv from 1.2.1 to 1.2.2 in
/foreign/python (#3150)
add e1b1b22a7 fix(go,csharp): remove duplicate consumer groups in
DeserializeClient/MapClient (#3164)
add 499a26d88 feat(connectors): implement Delta Lake Sink Connector (#2889)
add 48a297dfa chore(web): update dependencies (#3185)
add cca0e04e7 feat(configs): add ServerNgConfig schema with message_bus
section (#3189)
add eb20ac5ae feat(java): Implement CLI and resource provisioner for
pinned producer benchmark (#3159)
add fc2bf8977 Merge branch 'master' into
dependabot/uv/bdd/python/mako-1.3.11
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1344 ++++++++++++++++++--
Cargo.toml | 3 +
DEPENDENCIES.md | 73 ++
core/configs/src/lib.rs | 2 +
core/configs/src/server_ng_config/defaults.rs | 94 ++
core/configs/src/server_ng_config/displays.rs | 72 ++
core/configs/src/server_ng_config/message_bus.rs | 257 ++++
.../src/{server_config => server_ng_config}/mod.rs | 27 +-
core/configs/src/server_ng_config/server_ng.rs | 200 +++
core/configs/src/server_ng_config/validators.rs | 130 ++
.../example_config/connectors/delta_sink.toml} | 14 +-
core/connectors/sdk/src/convert.rs | 114 ++
.../sinks/{stdout_sink => delta_sink}/Cargo.toml | 11 +-
core/connectors/sinks/delta_sink/README.md | 92 ++
core/connectors/sinks/delta_sink/config.toml | 62 +
core/connectors/sinks/delta_sink/src/coercions.rs | 680 ++++++++++
core/connectors/sinks/delta_sink/src/lib.rs | 97 ++
core/connectors/sinks/delta_sink/src/sink.rs | 181 +++
core/connectors/sinks/delta_sink/src/storage.rs | 301 +++++
core/integration/Cargo.toml | 2 +
.../{stdout/stdout_sink.rs => delta/delta_sink.rs} | 120 +-
.../tests/connectors/{api => delta}/mod.rs | 2 +-
.../tests/connectors/{http => delta}/sink.toml | 2 +-
.../tests/connectors/fixtures/delta/fixture.rs | 391 ++++++
.../connectors/{http => fixtures/delta}/mod.rs | 4 +-
core/integration/tests/connectors/fixtures/mod.rs | 2 +
core/integration/tests/connectors/mod.rs | 1 +
core/server-ng/config.toml | 40 +
examples/rust/src/sink-data-producer/main.rs | 3 +
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 32 +-
.../binary_response_deserializer.go | 28 +-
foreign/java/{buildSrc => bench}/build.gradle.kts | 21 +-
.../java/org/apache/iggy/bench/IggyBench.java} | 18 +-
.../tcp/async/TcpAsyncPinnedProducer.java | 51 +
.../apache/iggy/bench/cli/IggyBenchCommand.java | 162 +++
.../iggy/bench/cli/PinnedProducerCommand.java | 111 ++
.../iggy/bench/exception/BenchmarkException.java} | 19 +-
.../iggy/bench/models/cli/GlobalCliArgs.java | 85 ++
.../bench/models/cli/PinnedProducerCliArgs.java | 43 +
.../models/provision/ProvisionedResources.java} | 4 +-
.../iggy/bench/provision/ResourceProvisioner.java | 100 ++
foreign/java/gradle/libs.versions.toml | 2 +
foreign/java/settings.gradle.kts | 3 +
foreign/python/uv.lock | 6 +-
web/package-lock.json | 1314 ++++++++++++-------
web/package.json | 40 +-
46 files changed, 5671 insertions(+), 689 deletions(-)
create mode 100644 core/configs/src/server_ng_config/defaults.rs
create mode 100644 core/configs/src/server_ng_config/displays.rs
create mode 100644 core/configs/src/server_ng_config/message_bus.rs
copy core/configs/src/{server_config => server_ng_config}/mod.rs (52%)
create mode 100644 core/configs/src/server_ng_config/server_ng.rs
create mode 100644 core/configs/src/server_ng_config/validators.rs
copy core/connectors/{sinks/stdout_sink/config.toml =>
runtime/example_config/connectors/delta_sink.toml} (79%)
copy core/connectors/sinks/{stdout_sink => delta_sink}/Cargo.toml (84%)
create mode 100644 core/connectors/sinks/delta_sink/README.md
create mode 100644 core/connectors/sinks/delta_sink/config.toml
create mode 100644 core/connectors/sinks/delta_sink/src/coercions.rs
create mode 100644 core/connectors/sinks/delta_sink/src/lib.rs
create mode 100644 core/connectors/sinks/delta_sink/src/sink.rs
create mode 100644 core/connectors/sinks/delta_sink/src/storage.rs
copy core/integration/tests/connectors/{stdout/stdout_sink.rs =>
delta/delta_sink.rs} (71%)
copy core/integration/tests/connectors/{api => delta}/mod.rs (98%)
copy core/integration/tests/connectors/{http => delta}/sink.toml (94%)
create mode 100644 core/integration/tests/connectors/fixtures/delta/fixture.rs
copy core/integration/tests/connectors/{http => fixtures/delta}/mod.rs (92%)
copy foreign/java/{buildSrc => bench}/build.gradle.kts (58%)
copy
foreign/java/{java-sdk/src/test/java/org/apache/iggy/identifier/StreamIdTest.java
=> bench/src/main/java/org/apache/iggy/bench/IggyBench.java} (71%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/benchmarks/tcp/async/TcpAsyncPinnedProducer.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/cli/IggyBenchCommand.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/cli/PinnedProducerCommand.java
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/message/PollingKind.java
=> bench/src/main/java/org/apache/iggy/bench/exception/BenchmarkException.java}
(75%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/cli/GlobalCliArgs.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/cli/PinnedProducerCliArgs.java
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/consumergroup/ConsumerGroupMember.java
=>
bench/src/main/java/org/apache/iggy/bench/models/provision/ProvisionedResources.java}
(85%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/provision/ResourceProvisioner.java
