This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch harness-derive
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 5a71754a8 Merge branch 'master' into harness-derive
add 8827588e8 feat(java): improve tests and clean up json mappings (#2658)
add 4f91d7d89 feat(java): add gradle wrapper with jar file autofetch
(#2659)
add e5cf2d2f4 feat(connectors): add connector version to stats endpoint
(#2660)
add 7732d55ee Merge branch 'master' into harness-derive
No new revisions were added by this update.
Summary of changes:
.github/actions/java-gradle/post-merge/action.yml | 18 +-
.github/actions/java-gradle/pre-merge/action.yml | 10 +-
.../actions/utils/setup-java-with-cache/action.yml | 21 +-
Cargo.lock | 20 +-
Cargo.toml | 2 +-
DEPENDENCIES.md | 20 +-
bdd/java/.gitignore | 3 +
bdd/java/Dockerfile | 12 +-
bdd/java/gradle/wrapper/gradle-wrapper.properties | 7 +
bdd/java/gradlew | 297 +++++++++++++++++++++
core/connectors/README.md | 2 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/runtime/README.md | 51 ++++
core/connectors/runtime/src/context.rs | 2 +
core/connectors/runtime/src/main.rs | 4 +
core/connectors/runtime/src/manager/sink.rs | 1 +
core/connectors/runtime/src/manager/source.rs | 1 +
core/connectors/runtime/src/sink.rs | 13 +
core/connectors/runtime/src/source.rs | 13 +
core/connectors/runtime/src/stats.rs | 14 +
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sdk/README.md | 4 +-
core/connectors/sdk/src/sink.rs | 7 +
core/connectors/sdk/src/source.rs | 7 +
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
examples/java/.gitignore | 3 +
examples/java/README.md | 24 +-
.../java/gradle/wrapper/gradle-wrapper.properties | 7 +
examples/java/gradlew | 297 +++++++++++++++++++++
foreign/java/.gitignore | 3 +
foreign/java/BUILD_AND_TEST.md | 36 +--
foreign/java/README.md | 26 +-
.../java/dev-support/checkstyle/suppressions.xml | 3 +
.../java/gradle/wrapper/gradle-wrapper.properties | 7 +
foreign/java/gradlew | 297 +++++++++++++++++++++
.../blocking/http/MessageMixin.java} | 32 +--
.../client/blocking/http/ObjectMapperFactory.java | 11 +-
.../blocking/http}/UserHeadersSerializer.java | 4 +-
.../java/org/apache/iggy/message/HeaderKey.java | 34 +--
.../java/org/apache/iggy/message/HeaderKind.java | 16 --
.../java/org/apache/iggy/message/HeaderValue.java | 74 ++---
.../main/java/org/apache/iggy/message/Message.java | 33 +--
.../java/org/apache/iggy/message/Partitioning.java | 6 +-
.../org/apache/iggy/serde/Base64Serializer.java | 35 ---
.../java/org/apache/iggy/user/Permissions.java | 7 +-
.../org/apache/iggy/user/StreamPermissions.java | 5 +-
.../iggy/client/blocking/IntegrationTest.java | 6 +
.../blocking/http/HeaderKindSerializationTest.java | 120 +++++++++
.../client/blocking/http/ObjectMapperTest.java | 286 ++++++++++++++++++++
.../apache/iggy/serde/BytesDeserializerTest.java | 76 ------
scripts/run-java-examples-from-readme.sh | 4 +-
58 files changed, 1656 insertions(+), 345 deletions(-)
create mode 100644 bdd/java/gradle/wrapper/gradle-wrapper.properties
create mode 100755 bdd/java/gradlew
create mode 100644 examples/java/gradle/wrapper/gradle-wrapper.properties
create mode 100755 examples/java/gradlew
create mode 100644 foreign/java/gradle/wrapper/gradle-wrapper.properties
create mode 100755 foreign/java/gradlew
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{serde/UserHeadersSerializer.java
=> client/blocking/http/MessageMixin.java} (55%)
rename foreign/java/java-sdk/src/main/java/org/apache/iggy/{serde =>
client/blocking/http}/UserHeadersSerializer.java (92%)
delete mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/serde/Base64Serializer.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/HeaderKindSerializationTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/ObjectMapperTest.java
