This is an automated email from the ASF dual-hosted git repository.
maciej pushed a change to branch szpont-golang-bdd
in repository https://gitbox.apache.org/repos/asf/iggy.git
from c9310bdfd fix(ci): pin ginkgo CLI to v2.23.4 to match go.mod
add fd638a283 feat(java): refactor SDK with fluent builder API and
exception hierarchy (#2630)
add 84965a3d1 Merge branch 'master' into szpont-golang-bdd
No new revisions were added by this update.
Summary of changes:
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 1 +
.../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 ++++++++++
95 files changed, 3676 insertions(+), 1238 deletions(-)
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
