This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch partition_superblock
in repository https://gitbox.apache.org/repos/asf/iggy.git
from df38b993a small fixes
add fbf99a6eb feat(java): add cluster metadata and leader redirection to
TCP client (#3745)
add 5c4865f55 docs(security): add SECURITY.md with ASF reporting process
(#3787)
add 3bc814dd7 fix(ci): use portable fallbacks for bash-4 builtins and GNU
sed in hook scripts (#3694)
add 935a7c2ba chore(deps): Bump the github-actions group with 2 updates
(#3817)
add 46d45b517 chore(deps): Bump the java group across 3 directories with 5
updates (#3816)
new cd97574b7 Merge branch 'master' into partition_superblock
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/_common.yml | 2 +-
.github/workflows/coverage-baseline.yml | 4 +-
.github/workflows/post-merge.yml | 2 +-
.github/workflows/stale-prs.yml | 2 +-
.typos.toml | 2 +
SECURITY.md | 61 ++++
bdd/docker-compose.cluster.yml | 3 +
bdd/docker-compose.yml | 6 +-
bdd/java/build.gradle.kts | 6 +-
.../apache/iggy/bdd/LeaderRedirectionSteps.java | 274 +++++++++++++++++
examples/java/build.gradle.kts | 2 +-
foreign/java/gradle.properties | 2 +-
foreign/java/gradle/libs.versions.toml | 6 +-
.../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/ci/license-headers.sh | 6 +-
scripts/ci/python-sdk-version-sync.sh | 10 +-
scripts/ci/sync-python-interpreter-version.sh | 26 +-
scripts/ci/sync-rustc-version.sh | 12 +-
scripts/run-bdd-tests.sh | 2 +-
scripts/verify-crates-publish.sh | 7 +-
51 files changed, 1889 insertions(+), 212 deletions(-)
create mode 100644 SECURITY.md
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
