This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch fix-e2e-latency-calc
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 91d9992c2 Merge branch 'master' into fix-e2e-latency-calc
add b34e737e0 fix(cli): disable keyring on musl targets (#2478)
add d3ad4a326 fix(ci): restore integration deps accidentally moved to
musl-excluded section (#2479)
add f1588b33d refactor(java): unify deserialization and serialization code
for tcp clients (#2477)
add 2c96da7fd fix(ci): add aarch64 builds to pre-merge and fix musl
linking (#2481)
add 4fae9a59a chore(repo): bump Rust version to 1.92.0 (#2480)
add 13143871b feat(ci): add TOML formatting with taplo (#2482)
add 49c6c5ba5 fix(ci): filter artifact download to exclude docker cache
(#2483)
add ff6695ba5 feat(server,web): embed Web UI into server behind iggy-web
feature (#2485)
add a5d569450 feat(server): NUMA awareness (#2412)
add a48878712 fix(ci): fix hwloc build for musl targets in release
workflow (#2486)
add 1593ac543 feat(ci): use native ARM64 runners and implement better
shared Docker cache (#2487)
add bf8e886e6 fix(ci): fix Docker build failures for server and connectors
(#2488)
add 25f1139dd fix(ci): add xz-dev and xz-static to Alpine Docker builds
for liblzma linking (#2490)
add dd7ae9bbc fix(ci): eliminate intermediate Docker tags using
push-by-digest (#2491)
add fec904d4f fix(ci): remove temporary tag cleanup job (#2492)
add d6a6d4ffe feat(server): add http.web_ui config option to control
embedded Web UI (#2494)
add 86ab7b8d3 Merge branch 'master' into fix-e2e-latency-calc
No new revisions were added by this update.
Summary of changes:
.github/actions/rust/pre-merge/action.yml | 30 ++
.github/actions/utils/docker-buildx/action.yml | 173 +++++--
.../actions/utils/setup-rust-with-cache/action.yml | 13 +
.github/config/components.yml | 3 +
.github/workflows/_build_rust_artifacts.yml | 14 +
.github/workflows/_common.yml | 30 ++
.github/workflows/_test.yml | 7 +-
.github/workflows/post-merge.yml | 146 +++++-
.github/workflows/publish.yml | 292 +++++++++++-
.pre-commit-config.yaml | 8 +
.taplo.toml | 75 +++
Cargo.lock | 492 +++++++++++++-------
Cargo.toml | 3 +-
DEPENDENCIES.md | 91 ++--
Dockerfile | 5 +-
bdd/python/Dockerfile | 2 +-
bdd/rust/Cargo.toml | 2 +-
bdd/rust/Dockerfile | 8 +-
cliff.toml | 2 +-
core/ai/mcp/Dockerfile | 9 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/dashboard/server/Dockerfile | 5 +-
core/common/Cargo.toml | 2 +-
core/common/src/types/message/user_headers.rs | 13 +-
core/configs/server.toml | 17 +-
core/connectors/runtime/Dockerfile | 14 +-
.../runtime/example_config/connectors/iceberg.toml | 1 -
core/integration/Cargo.toml | 2 +-
core/journal/Cargo.toml | 1 -
core/message_bus/Cargo.toml | 2 -
core/server/Cargo.toml | 10 +
core/server/Dockerfile | 27 +-
core/server/build.rs | 77 +++-
core/server/src/bootstrap.rs | 14 +-
core/server/src/configs/defaults.rs | 1 +
core/server/src/configs/displays.rs | 3 +-
core/server/src/configs/http.rs | 1 +
core/server/src/configs/sharding.rs | 512 ++++++++++++++++++++-
core/server/src/configs/validators.rs | 13 +
core/server/src/http/http_server.rs | 15 +
core/server/src/http/jwt/middleware.rs | 1 +
core/server/src/http/mod.rs | 2 +
core/server/src/http/web.rs | 83 ++++
core/server/src/main.rs | 43 +-
core/server/src/server_error.rs | 33 +-
core/server/src/slab/streams.rs | 64 +--
.../client/async/tcp/AsyncBytesDeserializer.java | 210 ---------
.../client/async/tcp/AsyncBytesSerializer.java | 237 ----------
.../client/async/tcp/ConsumerGroupsTcpClient.java | 15 +-
.../iggy/client/async/tcp/MessagesTcpClient.java | 8 +-
.../iggy/client/async/tcp/StreamsTcpClient.java | 19 +-
.../iggy/client/async/tcp/TopicsTcpClient.java | 19 +-
.../iggy/client/async/tcp/UsersTcpClient.java | 7 +-
.../blocking/tcp/ConsumerGroupsTcpClient.java | 8 +-
.../blocking/tcp/ConsumerOffsetTcpClient.java | 6 +-
.../client/blocking/tcp/InternalTcpClient.java | 1 +
.../client/blocking/tcp/MessagesTcpClient.java | 4 +-
.../client/blocking/tcp/PartitionsTcpClient.java | 3 +-
.../tcp/PersonalAccessTokensTcpClient.java | 12 +-
.../iggy/client/blocking/tcp/StreamsTcpClient.java | 10 +-
.../iggy/client/blocking/tcp/SystemTcpClient.java | 2 +
.../iggy/client/blocking/tcp/TopicsTcpClient.java | 12 +-
.../iggy/client/blocking/tcp/UsersTcpClient.java | 19 +-
.../apache/iggy/message/BigIntegerMessageId.java | 2 +-
.../blocking/tcp => serde}/BytesDeserializer.java | 48 +-
.../blocking/tcp => serde}/BytesSerializer.java | 49 +-
.../blocking/tcp => serde}/CommandCode.java | 6 +-
.../iggy/client/async/AsyncPollMessageTest.java | 25 -
.../client/blocking/tcp/BytesSerializerTest.java | 24 +
.../apache/iggy/serde/BytesDeserializerTest.java | 81 ++++
foreign/python/Cargo.toml | 5 +-
rust-toolchain.toml | 2 +-
scripts/ci/{trailing-newline.sh => taplo.sh} | 131 +++---
web/package-lock.json | 111 ++---
web/package.json | 7 +-
web/src/hooks.client.ts | 11 +-
web/src/hooks.server.ts | 73 ---
web/src/lib/api/ApiSchema.ts | 6 +-
web/src/lib/api/clientApi.ts | 106 +++++
web/src/lib/api/fetchRouteApi.ts | 35 +-
web/src/lib/api/handleFetchErrors.ts | 6 +-
web/src/lib/auth/authStore.svelte.ts | 125 +++++
web/src/lib/components/Breadcrumbs.svelte | 2 +-
web/src/lib/components/Header.svelte | 21 +-
.../lib/components/Layouts/SettingsLayout.svelte | 10 +-
web/src/lib/components/Logo/Logo.svelte | 5 +-
web/src/lib/components/Navbar.svelte | 15 +-
web/src/lib/types/appRoutes.ts | 10 +-
web/src/routes/+layout.ts | 64 +++
web/src/routes/api/proxy/+server.ts | 43 --
.../[partitionId=i32] => auth/logout}/+page.svelte | 14 +-
.../auth/logout/{+page.server.ts => +page.ts} | 27 +-
web/src/routes/auth/sign-in/+page.server.ts | 77 ----
web/src/routes/auth/sign-in/+page.svelte | 100 ++--
.../src/routes/auth/sign-in/+page.ts | 18 +-
.../dashboard/{+layout.server.ts => +layout.ts} | 45 +-
.../overview/{+page.server.ts => +page.ts} | 13 +-
.../dashboard/settings/server/+page.server.ts | 39 --
.../settings/server/+page.ts} | 13 +-
.../settings/users/{+page.server.ts => +page.ts} | 31 +-
web/src/routes/dashboard/streams/+layout.server.ts | 37 --
web/src/routes/dashboard/streams/+layout.svelte | 5 +-
.../+page.server.ts => streams/+layout.ts} | 17 +-
.../streams/[streamId=i32]/+page.server.ts | 40 --
.../dashboard/streams/[streamId=i32]/+page.svelte | 3 +-
.../dashboard/streams/[streamId=i32]/+page.ts} | 15 +-
.../topics/[topicId=i32]/+page.server.ts | 40 --
.../topics/[topicId=i32]/+page.svelte | 6 +-
.../[streamId=i32]/topics/[topicId=i32]/+page.ts} | 17 +-
.../messages/{+page.server.ts => +page.ts} | 29 +-
web/svelte.config.js | 21 +-
111 files changed, 2930 insertions(+), 1655 deletions(-)
create mode 100644 .taplo.toml
create mode 100644 core/server/src/http/web.rs
delete mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/AsyncBytesDeserializer.java
delete mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/AsyncBytesSerializer.java
rename
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/blocking/tcp =>
serde}/BytesDeserializer.java (90%)
rename
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/blocking/tcp =>
serde}/BytesSerializer.java (83%)
rename
foreign/java/java-sdk/src/main/java/org/apache/iggy/{client/blocking/tcp =>
serde}/CommandCode.java (96%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/serde/BytesDeserializerTest.java
copy scripts/ci/{trailing-newline.sh => taplo.sh} (54%)
delete mode 100644 web/src/hooks.server.ts
create mode 100644 web/src/lib/api/clientApi.ts
create mode 100644 web/src/lib/auth/authStore.svelte.ts
create mode 100644 web/src/routes/+layout.ts
delete mode 100644 web/src/routes/api/proxy/+server.ts
copy
web/src/routes/{dashboard/streams/[streamId=i32]/topics/[topicId=i32]/partitions/[partitionId=i32]
=> auth/logout}/+page.svelte (79%)
rename web/src/routes/auth/logout/{+page.server.ts => +page.ts} (67%)
delete mode 100644 web/src/routes/auth/sign-in/+page.server.ts
copy foreign/node/src/wire/message/index.ts =>
web/src/routes/auth/sign-in/+page.ts (68%)
rename web/src/routes/dashboard/{+layout.server.ts => +layout.ts} (50%)
copy web/src/routes/dashboard/overview/{+page.server.ts => +page.ts} (76%)
delete mode 100644 web/src/routes/dashboard/settings/server/+page.server.ts
rename web/src/routes/{+layout.server.ts =>
dashboard/settings/server/+page.ts} (73%)
rename web/src/routes/dashboard/settings/users/{+page.server.ts => +page.ts}
(63%)
delete mode 100644 web/src/routes/dashboard/streams/+layout.server.ts
copy web/src/routes/dashboard/{overview/+page.server.ts => streams/+layout.ts}
(69%)
delete mode 100644
web/src/routes/dashboard/streams/[streamId=i32]/+page.server.ts
copy web/src/{lib/domain/UserDetails.ts =>
routes/dashboard/streams/[streamId=i32]/+page.ts} (70%)
delete mode 100644
web/src/routes/dashboard/streams/[streamId=i32]/topics/[topicId=i32]/+page.server.ts
rename web/src/routes/dashboard/{overview/+page.server.ts =>
streams/[streamId=i32]/topics/[topicId=i32]/+page.ts} (69%)
rename
web/src/routes/dashboard/streams/[streamId=i32]/topics/[topicId=i32]/partitions/[partitionId=i32]/messages/{+page.server.ts
=> +page.ts} (79%)
