This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch stale-pr
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 7c359d425 ci: add stale PR workflow
add fd638a283 feat(java): refactor SDK with fluent builder API and
exception hierarchy (#2630)
add d4f9ebc10 fix(ci): pin ginkgo CLI to v2.23.4 to match go.mod (#2642)
add 393b0f6fa feat(connectors): extend published stats (#2640)
add 9f0057685 chore(repo): bump Rust version to 1.93.0 (#2644)
add f2c56d8fa feat(metadata): expose metadata generics and create journal
handle (#2624)
add e84daf4e0 perf(ci): optimize hot dependencies in dev profile (#2645)
add 6c3b63924 Merge branch 'master' into stale-pr
No new revisions were added by this update.
Summary of changes:
.github/actions/go/pre-merge/action.yml | 2 +-
.github/actions/rust/pre-merge/action.yml | 27 +-
.github/actions/utils/docker-buildx/action.yml | 4 +-
.github/workflows/_common.yml | 20 --
.github/workflows/_detect.yml | 2 -
.github/workflows/_test.yml | 2 -
.github/workflows/_test_bdd.yml | 2 -
.github/workflows/_test_examples.yml | 2 -
.github/workflows/pre-merge.yml | 3 -
Cargo.toml | 16 +-
Dockerfile | 2 +-
bdd/go/Dockerfile | 2 +-
bdd/java/Dockerfile | 2 +-
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 1 +
bdd/python/Dockerfile | 2 +-
bdd/rust/Dockerfile | 2 +-
core/ai/mcp/Dockerfile | 2 +-
core/bench/dashboard/server/Dockerfile | 2 +-
core/common/src/lib.rs | 35 ++-
core/common/src/utils/mod.rs | 35 ++-
.../{server/src => common/src/utils}/versioning.rs | 27 +-
core/connectors/runtime/Dockerfile | 2 +-
core/connectors/runtime/src/stats.rs | 30 +-
core/integration/tests/state/mod.rs | 5 +-
core/journal/src/lib.rs | 24 +-
core/metadata/src/impls/metadata.rs | 89 +++---
core/server/Dockerfile | 2 +-
core/server/src/bootstrap.rs | 2 +-
core/server/src/lib.rs | 8 +-
core/server/src/main.rs | 2 +-
core/server/src/shard/builder.rs | 5 +-
core/server/src/shard/mod.rs | 7 +-
core/server/src/shard/system/info.rs | 5 +-
core/server/src/state/file.rs | 5 +-
.../iggy/examples/async/AsyncConsumerExample.java | 10 +-
.../apache/iggy/examples/async/AsyncProducer.java | 12 +-
.../consumer/GettingStartedConsumer.java | 2 +-
.../producer/GettingStartedProducer.java | 2 +-
.../consumer/MessageEnvelopeConsumer.java | 2 +-
.../producer/MessageEnvelopeProducer.java | 2 +-
.../consumer/MessageHeadersConsumer.java | 2 +-
.../producer/MessageHeadersProducer.java | 2 +-
.../multitenant/consumer/MultiTenantConsumer.java | 4 +-
.../multitenant/producer/MultiTenantProducer.java | 4 +-
.../sinkdataproducer/SinkDataProducer.java | 2 +-
.../iggy/examples/streambuilder/StreamBasic.java | 2 +-
foreign/java/README.md | 129 ++++++++
.../flink/source/IggyPartitionSplitReader.java | 2 +-
.../iggy/connector/flink/source/IggySource.java | 12 +-
.../flink/source/IggySourceSplitEnumerator.java | 2 +-
.../flink/example/AsyncTcpMessagePollTest.java | 30 +-
.../flink/example/AsyncTcpMessageSendTest.java | 26 +-
.../iggy/flink/example/SendTextDataTest.java | 11 +-
.../pinot/consumer/IggyPartitionGroupConsumer.java | 9 +-
.../pinot/metadata/IggyStreamMetadataProvider.java | 9 +-
foreign/java/java-sdk/build.gradle.kts | 18 ++
.../src/main/java/org/apache/iggy/Iggy.java | 86 +++++-
.../src/main/java/org/apache/iggy/IggyVersion.java | 135 ++++++++
.../org/apache/iggy/builder/HttpClientBuilder.java | 66 ++++
.../org/apache/iggy/builder/TcpClientBuilder.java | 86 ++++++
.../apache/iggy/client/async/MessagesClient.java | 12 +-
.../apache/iggy/client/async/StreamsClient.java | 22 +-
.../org/apache/iggy/client/async/TopicsClient.java | 10 +-
.../org/apache/iggy/client/async/UsersClient.java | 4 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 307 +++----------------
.../async/tcp/AsyncIggyTcpClientBuilder.java | 246 +++++++++++++++
.../iggy/client/async/tcp/AsyncTcpConnection.java | 17 +-
.../client/async/tcp/ConsumerGroupsTcpClient.java | 4 +-
.../iggy/client/async/tcp/MessagesTcpClient.java | 30 +-
.../iggy/client/async/tcp/StreamsTcpClient.java | 34 +--
.../iggy/client/async/tcp/TopicsTcpClient.java | 60 ++--
.../iggy/client/async/tcp/UsersTcpClient.java | 13 +-
.../iggy/client/blocking/IggyClientBuilder.java | 37 ---
.../blocking/http/ConsumerGroupsHttpClient.java | 5 +-
.../iggy/client/blocking/http/IggyHttpClient.java | 76 ++++-
.../blocking/http/IggyHttpClientBuilder.java | 237 +++++++++++++++
.../client/blocking/http/InternalHttpClient.java | 75 ++++-
.../client/blocking/http/SystemHttpClient.java | 3 +-
.../iggy/client/blocking/http/UrlValidator.java | 60 ++++
.../iggy/client/blocking/http/UsersHttpClient.java | 5 +-
.../client/blocking/http/error/IggyHttpError.java | 22 --
.../iggy/client/blocking/tcp/IggyTcpClient.java | 338 +++++----------------
.../client/blocking/tcp/IggyTcpClientBuilder.java | 245 +++++++++++++++
.../client/blocking/tcp/InternalTcpClient.java | 15 +-
.../iggy/client/blocking/tcp/UsersTcpClient.java | 5 +-
.../java/org/apache/iggy/config/RetryPolicy.java | 130 ++++++++
.../exception/IggyAuthenticationException.java | 70 +++++
.../iggy/exception/IggyAuthorizationException.java | 63 ++++
.../IggyClientException.java} | 32 +-
.../iggy/exception/IggyConflictException.java | 69 +++++
.../exception/IggyConnectionClosedException.java | 52 ++++
.../IggyConnectionException.java} | 32 +-
.../IggyEmptyResponseException.java} | 28 +-
.../org/apache/iggy/exception/IggyErrorCode.java | 162 ++++++++++
.../org/apache/iggy/exception/IggyException.java | 58 ++++
.../IggyInvalidArgumentException.java} | 32 +-
.../IggyMalformedResponseException.java} | 29 +-
.../IggyMissingCredentialsException.java} | 34 ++-
.../IggyNotConnectedException.java} | 25 +-
.../IggyOperationNotSupportedException.java | 72 +++++
.../IggyProtocolException.java} | 32 +-
.../exception/IggyResourceNotFoundException.java | 76 +++++
.../apache/iggy/exception/IggyServerException.java | 206 +++++++++++++
.../IggyTimeoutException.java} | 36 ++-
.../IggyTlsException.java} | 32 +-
.../iggy/exception/IggyValidationException.java | 80 +++++
.../org/apache/iggy/identifier/Identifier.java | 5 +-
.../org/apache/iggy/message/BytesMessageId.java | 3 +-
.../java/org/apache/iggy/message/HeaderKind.java | 4 +-
.../java/org/apache/iggy/message/MessageState.java | 4 +-
.../java/org/apache/iggy/message/Partitioning.java | 3 +-
.../org/apache/iggy/serde/BytesSerializer.java | 11 +-
.../apache/iggy/topic/CompressionAlgorithm.java | 4 +-
.../main/java/org/apache/iggy/user/UserStatus.java | 3 +-
.../src/main/resources/iggy-version.properties | 3 +
.../src/test/java/org/apache/iggy/IggyTest.java | 74 ++++-
.../test/java/org/apache/iggy/IggyVersionTest.java | 113 +++++++
.../client/async/AsyncClientIntegrationTest.java | 41 ++-
.../iggy/client/async/AsyncPollMessageTest.java | 31 +-
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 187 ++----------
.../iggy/client/blocking/IntegrationTest.java | 1 +
.../client/blocking/http/HttpClientFactory.java | 3 +-
.../client/blocking/http/UrlValidatorTest.java | 90 ++++++
.../client/blocking/tcp/BytesSerializerTest.java | 13 +-
.../blocking/tcp/IggyTcpClientBuilderTest.java | 103 +++----
.../iggy/client/blocking/tcp/TcpClientFactory.java | 13 +-
.../apache/iggy/exception/IggyErrorCodeTest.java | 149 +++++++++
.../iggy/exception/IggyServerExceptionTest.java | 156 ++++++++++
rust-toolchain.toml | 2 +-
scripts/check-backwards-compat.sh | 4 +-
130 files changed, 3869 insertions(+), 1428 deletions(-)
rename core/{server/src => common/src/utils}/versioning.rs (94%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/IggyVersion.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/builder/HttpClientBuilder.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/builder/TcpClientBuilder.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/AsyncIggyTcpClientBuilder.java
delete mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/IggyClientBuilder.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/http/IggyHttpClientBuilder.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/http/UrlValidator.java
delete mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/http/error/IggyHttpError.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/tcp/IggyTcpClientBuilder.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/config/RetryPolicy.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyAuthenticationException.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyAuthorizationException.java
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/async/UsersClient.java
=> exception/IggyClientException.java} (54%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyConflictException.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyConnectionClosedException.java
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/async/UsersClient.java
=> exception/IggyConnectionException.java} (52%)
rename
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/blocking/IggyClient.java
=> exception/IggyEmptyResponseException.java} (53%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyErrorCode.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyException.java
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/async/UsersClient.java
=> exception/IggyInvalidArgumentException.java} (51%)
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/async/UsersClient.java
=> exception/IggyMalformedResponseException.java} (55%)
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/async/UsersClient.java
=> exception/IggyMissingCredentialsException.java} (50%)
rename
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/blocking/http/error/IggyHttpException.java
=> exception/IggyNotConnectedException.java} (57%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyOperationNotSupportedException.java
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/async/UsersClient.java
=> exception/IggyProtocolException.java} (53%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyResourceNotFoundException.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyServerException.java
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/async/UsersClient.java
=> exception/IggyTimeoutException.java} (52%)
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/async/UsersClient.java
=> exception/IggyTlsException.java} (54%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/exception/IggyValidationException.java
create mode 100644
foreign/java/java-sdk/src/main/resources/iggy-version.properties
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/IggyVersionTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/UrlValidatorTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/exception/IggyErrorCodeTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/exception/IggyServerExceptionTest.java
