This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch refactor-binary-7-http
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit b3d5cb7ae fix(server): restore partition count validation in binary
handlers
omit 45545c8ef refactor(server): extract shared HTTP DTOs to iggy_common
omit 5719d1a3a refactor(server): switch WAL to wire types and move domain
commands to http DTOs
omit 45556f487 refactor(server): delete dead command structs and simplify
SDK traits
omit a3485082d refactor(server): route wire types through
ShardRequestPayload and SDK
add b55d065d8 feat(metadata): Persistent WAL journal with recovery and
compaction (#2916)
add 9ee1f6dfa feat(java): Support connection timeout (#3026)
add 411a697eb ci: add Helm chart validation (#3019)
add 2018a4393 refactor(server): route wire types through
ShardRequestPayload and SDK
add 6c4971214 refactor(server): delete dead command structs and simplify
SDK traits
add 4a8690a95 refactor(server): switch WAL to wire types and move domain
commands to http DTOs
add 5c3addfea refactor(server): extract shared HTTP DTOs to iggy_common
add 53bb42b86 refactor(server): remove dead BytesSerializable impls from
10 types
add 975d67e4a refactor(server): migrate WAL to WireEncode/WireDecode traits
add 810b90f07 refactor(sdk): delete BytesSerializable trait entirely
add db9b7df3b fix(server): restore partition count validation in binary
handlers
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (b3d5cb7ae)
\
N -- N -- N refs/heads/refactor-binary-7-http (db9b7df3b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/actions/utils/setup-helm-tools/action.yml | 67 ++
.github/config/components.yml | 5 +
.github/workflows/_test.yml | 23 +
Cargo.lock | 10 +
core/binary_protocol/src/lib.rs | 6 +-
.../src/commands/binary_message/poll_messages.rs | 8 +-
.../src/commands/binary_message/send_messages.rs | 4 +-
core/common/src/http/messages/poll_messages.rs | 44 +-
core/common/src/http/messages/send_messages.rs | 78 +--
core/common/src/lib.rs | 1 -
core/common/src/traits/binary_impls/messages.rs | 68 +-
core/common/src/traits/bytes_serializable.rs | 41 --
core/common/src/traits/mod.rs | 1 -
core/common/src/types/cluster/metadata.rs | 95 +--
core/common/src/types/cluster/node.rs | 98 +--
core/common/src/types/cluster/role.rs | 27 +-
core/common/src/types/cluster/status.rs | 27 +-
.../src/types/cluster/transport_endpoints.rs | 69 --
core/common/src/types/configuration/transport.rs | 23 +-
core/common/src/types/consumer/consumer_kind.rs | 27 -
core/common/src/types/identifier/mod.rs | 76 +--
core/common/src/types/message/iggy_message.rs | 138 ++--
core/common/src/types/message/message_header.rs | 8 +-
.../src/types/message/message_header_view.rs | 25 +-
core/common/src/types/message/message_view.rs | 24 +-
core/common/src/types/message/messages_batch.rs | 24 +-
.../common/src/types/message/messages_batch_mut.rs | 6 +-
core/common/src/types/message/mod.rs | 3 +-
core/common/src/types/message/partitioning.rs | 71 +-
core/common/src/types/message/polled_messages.rs | 12 +-
core/common/src/types/message/polling_strategy.rs | 27 -
core/common/src/types/message/user_headers.rs | 178 +++--
.../src/types/permissions/permissions_global.rs | 258 --------
core/common/src/wire_conversions.rs | 27 +
.../tests/server/scenarios/offset_scenario.rs | 4 +-
.../tests/server/scenarios/timestamp_scenario.rs | 4 +-
core/integration/tests/state/file.rs | 2 +-
core/journal/Cargo.toml | 7 +
core/journal/src/file_storage.rs | 149 +++++
core/journal/src/lib.rs | 43 +-
core/journal/src/metadata_journal.rs | 717 +++++++++++++++++++++
core/metadata/Cargo.toml | 6 +
core/metadata/src/impls/metadata.rs | 211 +++++-
core/metadata/src/impls/mod.rs | 4 +
core/metadata/src/impls/recovery.rs | 269 ++++++++
core/metadata/src/stm/snapshot.rs | 54 ++
core/partitions/src/iggy_partition.rs | 6 +-
core/partitions/src/journal.rs | 46 +-
core/partitions/src/log.rs | 2 +-
core/sdk/src/prelude.rs | 9 +-
core/server/src/shard/system/messages.rs | 3 +-
core/server/src/state/command.rs | 255 ++++----
core/server/src/state/entry.rs | 70 +-
core/server/src/state/file.rs | 13 +-
core/server/src/state/models.rs | 2 +-
core/simulator/src/deps.rs | 33 +-
core/simulator/src/replica.rs | 13 +-
.../message-compression/consumer/main.rs | 2 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 7 +-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 54 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 17 +-
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 74 +++
helm/charts/iggy/README.md | 79 ++-
helm/charts/iggy/templates/hpa.yaml | 13 +-
helm/charts/iggy/templates/ingress.yaml | 12 +-
scripts/ci/setup-helm-smoke-cluster.sh | 235 +++++++
scripts/ci/setup-helm-tools.sh | 111 ++++
scripts/ci/test-helm.sh | 452 +++++++++++++
68 files changed, 3106 insertions(+), 1471 deletions(-)
create mode 100644 .github/actions/utils/setup-helm-tools/action.yml
delete mode 100644 core/common/src/traits/bytes_serializable.rs
create mode 100644 core/journal/src/file_storage.rs
create mode 100644 core/journal/src/metadata_journal.rs
create mode 100644 core/metadata/src/impls/recovery.rs
create mode 100755 scripts/ci/setup-helm-smoke-cluster.sh
create mode 100755 scripts/ci/setup-helm-tools.sh
create mode 100755 scripts/ci/test-helm.sh
