This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 60b878923 perf(server-ng): compute batch checksum in a single produce
pass (#3746)
add fbf99a6eb feat(java): add cluster metadata and leader redirection to
TCP client (#3745)
No new revisions were added by this update.
Summary of changes:
bdd/docker-compose.cluster.yml | 3 +
bdd/docker-compose.yml | 6 +-
.../apache/iggy/bdd/LeaderRedirectionSteps.java | 274 +++++++++++++++++
foreign/java/gradle.properties | 2 +-
.../tcp/package-info.java => ConnectionInfo.java} | 26 +-
.../org/apache/iggy/client/async/SystemClient.java | 8 +
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 199 +++++++++++--
.../iggy/client/async/tcp/AsyncTcpConnection.java | 73 +++--
.../client/async/tcp/ConsumerGroupsTcpClient.java | 23 +-
.../client/async/tcp/ConsumerOffsetsTcpClient.java | 15 +-
.../iggy/client/async/tcp/LeaderAwareness.java | 282 ++++++++++++++++++
.../client/async/tcp/LoginRedirectionHook.java | 47 +++
.../iggy/client/async/tcp/MessagesTcpClient.java | 15 +-
.../iggy/client/async/tcp/PartitionsTcpClient.java | 27 +-
.../async/tcp/PersonalAccessTokensTcpClient.java | 32 +-
.../iggy/client/async/tcp/StreamsTcpClient.java | 21 +-
.../iggy/client/async/tcp/SystemTcpClient.java | 53 +++-
.../iggy/client/async/tcp/TopicsTcpClient.java | 25 +-
.../iggy/client/async/tcp/UsersTcpClient.java | 42 ++-
.../apache/iggy/client/blocking/SystemClient.java | 3 +
.../client/blocking/http/SystemHttpClient.java | 8 +
.../iggy/client/blocking/tcp/IggyTcpClient.java | 12 +
.../iggy/client/blocking/tcp/SystemTcpClient.java | 6 +
.../org/apache/iggy/cluster/ClusterMetadata.java} | 15 +-
.../HeaderEntry.java => cluster/ClusterNode.java} | 14 +-
.../ClusterNodeRole.java} | 29 +-
.../ClusterNodeStatus.java} | 35 ++-
.../TransportEndpoints.java} | 13 +-
.../iggy/{stream => cluster}/package-info.java | 2 +-
.../org/apache/iggy/serde/BytesDeserializer.java | 47 +++
.../java/org/apache/iggy/serde/CommandCode.java | 1 +
.../client/async/tcp/IggyResponseHandlerTest.java | 60 ++++
.../iggy/client/async/tcp/LeaderAwarenessTest.java | 328 +++++++++++++++++++++
.../iggy/client/blocking/SystemClientBaseTest.java | 18 ++
.../client/blocking/tcp/SystemTcpClientTest.java | 10 +
.../apache/iggy/serde/BytesDeserializerTest.java | 177 +++++++++++
scripts/run-bdd-tests.sh | 2 +-
37 files changed, 1772 insertions(+), 181 deletions(-)
create mode 100644
bdd/java/src/test/java/org/apache/iggy/bdd/LeaderRedirectionSteps.java
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/{blocking/tcp/package-info.java
=> ConnectionInfo.java} (61%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/LeaderAwareness.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/LoginRedirectionHook.java
copy
foreign/java/{bench/src/main/java/org/apache/iggy/bench/models/common/generator/DataBatch.java
=> java-sdk/src/main/java/org/apache/iggy/cluster/ClusterMetadata.java} (70%)
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{message/HeaderEntry.java
=> cluster/ClusterNode.java} (65%)
copy foreign/java/java-sdk/src/main/java/org/apache/iggy/{user/UserStatus.java
=> cluster/ClusterNodeRole.java} (64%)
copy foreign/java/java-sdk/src/main/java/org/apache/iggy/{user/UserStatus.java
=> cluster/ClusterNodeStatus.java} (57%)
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{message/HeaderEntry.java
=> cluster/TransportEndpoints.java} (69%)
copy foreign/java/java-sdk/src/main/java/org/apache/iggy/{stream =>
cluster}/package-info.java (96%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/IggyResponseHandlerTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/LeaderAwarenessTest.java
