This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch fix-dockerhub
in repository https://gitbox.apache.org/repos/asf/iggy.git
from c8192c99e fix(ci): skip stable Docker tags in check-tags during
auto-publish
add 78ef2b9ee docs(java): add async client JavaDoc and usage guide (#2711)
add 2dca380ba refactor(metadata): improve the stm update method (#2757)
new 38c274678 Merge branch 'master' into fix-dockerhub
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:
core/common/src/lib.rs | 1 +
.../common/src/types/either.rs | 9 +-
core/common/src/types/mod.rs | 1 +
core/metadata/src/stm/mod.rs | 46 ++-
core/metadata/src/stm/mux.rs | 28 +-
examples/java/README.md | 95 +++++-
examples/java/build.gradle.kts | 5 +-
.../apache/iggy/examples/async/AsyncConsumer.java | 349 +++++++++++++++++++++
.../iggy/examples/async/AsyncConsumerExample.java | 157 ---------
.../apache/iggy/examples/async/AsyncProducer.java | 240 +++++++-------
foreign/java/README.md | 9 +-
.../iggy/client/async/ConsumerGroupsClient.java | 58 +++-
.../apache/iggy/client/async/MessagesClient.java | 126 ++++++--
.../apache/iggy/client/async/StreamsClient.java | 99 ++++++
.../org/apache/iggy/client/async/TopicsClient.java | 103 ++++--
.../org/apache/iggy/client/async/UsersClient.java | 48 ++-
.../org/apache/iggy/client/async/package-info.java | 57 ++++
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 112 ++++++-
.../apache/iggy/client/async/tcp/package-info.java | 48 +++
19 files changed, 1177 insertions(+), 414 deletions(-)
copy foreign/go/contracts/connection_info.go =>
core/common/src/types/either.rs (89%)
create mode 100644
examples/java/src/main/java/org/apache/iggy/examples/async/AsyncConsumer.java
delete mode 100644
examples/java/src/main/java/org/apache/iggy/examples/async/AsyncConsumerExample.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/package-info.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/package-info.java
