You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by hg...@apache.org on 2025/11/24 09:02:38 UTC
(iggy) branch cluster-metadata-port updated (7b0721fce -> 7f3895564)
This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch cluster-metadata-port
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 7b0721fce update versions to edge
new 7f3895564 update versions to edge
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 (7b0721fce)
\
N -- N -- N refs/heads/cluster-metadata-port (7f3895564)
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.
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/utils/byte_size.rs | 45 +++++++++++++++++++++++++--
core/integration/tests/config_provider/mod.rs | 25 +++++++++------
core/server/src/configs/config_provider.rs | 3 --
3 files changed, 59 insertions(+), 14 deletions(-)
(iggy) 01/01: update versions to edge
Posted by hg...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a commit to branch cluster-metadata-port
in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 7f38955646f7189a3253d10e96f9c3d8756ee9ef
Author: Hubert Gruszecki <h....@gmail.com>
AuthorDate: Mon Nov 24 09:16:29 2025 +0100
update versions to edge
---
Cargo.lock | 18 +++++------
Cargo.toml | 8 ++---
DEPENDENCIES.md | 18 +++++------
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/utils/byte_size.rs | 45 +++++++++++++++++++++++++--
core/connectors/runtime/Cargo.toml | 2 +-
core/integration/tests/config_provider/mod.rs | 25 +++++++++------
core/sdk/Cargo.toml | 2 +-
core/server/Cargo.toml | 2 +-
core/server/src/configs/config_provider.rs | 3 --
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/java/gradle.properties | 2 +-
foreign/node/package-lock.json | 2 +-
foreign/node/package.json | 2 +-
foreign/python/Cargo.toml | 4 +--
foreign/python/pyproject.toml | 2 +-
web/package.json | 2 +-
22 files changed, 98 insertions(+), 53 deletions(-)
diff --git a/Cargo.lock b/Cargo.lock
index 59d631860..76612eb86 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -4607,7 +4607,7 @@ dependencies = [
[[package]]
name = "iggy"
-version = "0.8.0"
+version = "0.8.0-edge.6"
dependencies = [
"async-broadcast",
"async-dropper",
@@ -4639,7 +4639,7 @@ dependencies = [
[[package]]
name = "iggy-bench"
-version = "0.3.0"
+version = "0.3.0-edge.4"
dependencies = [
"async-trait",
"bench-report",
@@ -4669,7 +4669,7 @@ dependencies = [
[[package]]
name = "iggy-bench-dashboard-server"
-version = "0.5.0"
+version = "0.5.0-edge.5"
dependencies = [
"actix-cors",
"actix-files",
@@ -4696,7 +4696,7 @@ dependencies = [
[[package]]
name = "iggy-cli"
-version = "0.10.0"
+version = "0.10.0-edge.4"
dependencies = [
"ahash 0.8.12",
"anyhow",
@@ -4716,7 +4716,7 @@ dependencies = [
[[package]]
name = "iggy-connectors"
-version = "0.2.0"
+version = "0.2.0-edge.4"
dependencies = [
"async-trait",
"axum",
@@ -4749,7 +4749,7 @@ dependencies = [
[[package]]
name = "iggy-mcp"
-version = "0.2.0"
+version = "0.2.0-edge.4"
dependencies = [
"axum",
"axum-server",
@@ -4771,7 +4771,7 @@ dependencies = [
[[package]]
name = "iggy_binary_protocol"
-version = "0.8.0"
+version = "0.8.0-edge.6"
dependencies = [
"anyhow",
"async-broadcast",
@@ -4792,7 +4792,7 @@ dependencies = [
[[package]]
name = "iggy_common"
-version = "0.8.0"
+version = "0.8.0-edge.6"
dependencies = [
"aes-gcm",
"ahash 0.8.12",
@@ -8349,7 +8349,7 @@ dependencies = [
[[package]]
name = "server"
-version = "0.6.0"
+version = "0.6.0-edge.6"
dependencies = [
"ahash 0.8.12",
"anyhow",
diff --git a/Cargo.toml b/Cargo.toml
index f598515fd..ddf1057c4 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -128,10 +128,10 @@ human-repr = "1.1.0"
humantime = "2.3.0"
iceberg = "=0.6.0"
iceberg-catalog-rest = "=0.6.0"
-iggy = { path = "core/sdk", version = "0.8.0" }
-iggy_binary_protocol = { path = "core/binary_protocol", version = "0.8.0" }
-iggy_common = { path = "core/common", version = "0.8.0" }
-iggy_connector_sdk = { path = "core/connectors/sdk", version = "0.1.0" }
+iggy = { path = "core/sdk", version = "0.8.0-edge.6" }
+iggy_binary_protocol = { path = "core/binary_protocol", version = "0.8.0-edge.6" }
+iggy_common = { path = "core/common", version = "0.8.0-edge.6" }
+iggy_connector_sdk = { path = "core/connectors/sdk", version = "0.1.0-edge.4" }
integration = { path = "core/integration" }
keyring = { version = "3.6.3", features = ["sync-secret-service", "vendored"] }
lazy_static = "1.5.0"
diff --git a/DEPENDENCIES.md b/DEPENDENCIES.md
index 4314f3ed2..ac6e79033 100644
--- a/DEPENDENCIES.md
+++ b/DEPENDENCIES.md
@@ -403,14 +403,14 @@ icu_provider: 2.1.1, "Unicode-3.0",
ident_case: 1.0.1, "Apache-2.0 OR MIT",
idna: 1.1.0, "Apache-2.0 OR MIT",
idna_adapter: 1.2.1, "Apache-2.0 OR MIT",
-iggy: 0.8.0, "Apache-2.0",
-iggy-bench: 0.3.0, "Apache-2.0",
-iggy-bench-dashboard-server: 0.5.0, "Apache-2.0",
-iggy-cli: 0.10.0, "Apache-2.0",
-iggy-connectors: 0.2.0, "Apache-2.0",
-iggy-mcp: 0.2.0, "Apache-2.0",
-iggy_binary_protocol: 0.8.0, "Apache-2.0",
-iggy_common: 0.8.0, "Apache-2.0",
+iggy: 0.8.0-edge.6, "Apache-2.0",
+iggy-bench: 0.3.0-edge.4, "Apache-2.0",
+iggy-bench-dashboard-server: 0.5.0-edge.5, "Apache-2.0",
+iggy-cli: 0.10.0-edge.4, "Apache-2.0",
+iggy-connectors: 0.2.0-edge.4, "Apache-2.0",
+iggy-mcp: 0.2.0-edge.4, "Apache-2.0",
+iggy_binary_protocol: 0.8.0-edge.6, "Apache-2.0",
+iggy_common: 0.8.0-edge.6, "Apache-2.0",
iggy_connector_elasticsearch_sink: 0.1.0, "Apache-2.0",
iggy_connector_elasticsearch_source: 0.1.0, "Apache-2.0",
iggy_connector_iceberg_sink: 0.1.0, "Apache-2.0",
@@ -733,7 +733,7 @@ serde_with_macros: 3.16.0, "Apache-2.0 OR MIT",
serde_yaml_ng: 0.10.0, "MIT",
serial_test: 3.2.0, "MIT",
serial_test_derive: 3.2.0, "MIT",
-server: 0.6.0, "Apache-2.0",
+server: 0.6.0-edge.6, "Apache-2.0",
sha1: 0.10.6, "Apache-2.0 OR MIT",
sha2: 0.10.9, "Apache-2.0 OR MIT",
sharded-slab: 0.1.7, "MIT",
diff --git a/core/ai/mcp/Cargo.toml b/core/ai/mcp/Cargo.toml
index b6432de4e..6fd58436c 100644
--- a/core/ai/mcp/Cargo.toml
+++ b/core/ai/mcp/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-mcp"
-version = "0.2.0"
+version = "0.2.0-edge.4"
description = "MCP Server for Iggy message streaming platform"
edition = "2024"
license = "Apache-2.0"
diff --git a/core/bench/Cargo.toml b/core/bench/Cargo.toml
index 2557e0b47..e2c2a46d1 100644
--- a/core/bench/Cargo.toml
+++ b/core/bench/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-bench"
-version = "0.3.0"
+version = "0.3.0-edge.4"
edition = "2024"
license = "Apache-2.0"
repository = "https://github.com/apache/iggy"
diff --git a/core/bench/dashboard/server/Cargo.toml b/core/bench/dashboard/server/Cargo.toml
index 8d7ca08db..2e34186de 100644
--- a/core/bench/dashboard/server/Cargo.toml
+++ b/core/bench/dashboard/server/Cargo.toml
@@ -18,7 +18,7 @@
[package]
name = "iggy-bench-dashboard-server"
license = "Apache-2.0"
-version = "0.5.0"
+version = "0.5.0-edge.5"
edition = "2024"
[dependencies]
diff --git a/core/binary_protocol/Cargo.toml b/core/binary_protocol/Cargo.toml
index c8fd2c7cd..3cabe2625 100644
--- a/core/binary_protocol/Cargo.toml
+++ b/core/binary_protocol/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy_binary_protocol"
-version = "0.8.0"
+version = "0.8.0-edge.6"
description = "Iggy is the persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second."
edition = "2024"
license = "Apache-2.0"
diff --git a/core/cli/Cargo.toml b/core/cli/Cargo.toml
index 4d8b74248..2c3c64dc9 100644
--- a/core/cli/Cargo.toml
+++ b/core/cli/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-cli"
-version = "0.10.0"
+version = "0.10.0-edge.4"
edition = "2024"
authors = ["bartosz.ciesla@gmail.com"]
repository = "https://github.com/apache/iggy"
diff --git a/core/common/Cargo.toml b/core/common/Cargo.toml
index 78ab51e6c..0ccc279bf 100644
--- a/core/common/Cargo.toml
+++ b/core/common/Cargo.toml
@@ -16,7 +16,7 @@
# under the License.
[package]
name = "iggy_common"
-version = "0.8.0"
+version = "0.8.0-edge.6"
description = "Iggy is the persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second."
edition = "2024"
license = "Apache-2.0"
diff --git a/core/common/src/utils/byte_size.rs b/core/common/src/utils/byte_size.rs
index 13bb70098..2ccf58bee 100644
--- a/core/common/src/utils/byte_size.rs
+++ b/core/common/src/utils/byte_size.rs
@@ -20,7 +20,7 @@ use super::duration::IggyDuration;
use crate::IggyError;
use byte_unit::{Byte, UnitType};
use core::fmt;
-use serde::{Deserialize, Serialize};
+use serde::{Deserialize, Deserializer, Serialize};
use std::{
iter::Sum,
ops::{Add, AddAssign, Sub, SubAssign},
@@ -53,9 +53,50 @@ use std::{
/// assert_eq!("1.00 GB", size.as_human_string());
/// assert_eq!("1.00 GB", format!("{}", size));
/// ```
-#[derive(Debug, Copy, Clone, PartialEq, Serialize, Deserialize)]
+#[derive(Debug, Copy, Clone, PartialEq, Serialize)]
pub struct IggyByteSize(Byte);
+impl<'de> Deserialize<'de> for IggyByteSize {
+ fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
+ where
+ D: Deserializer<'de>,
+ {
+ use serde::de::{self, Visitor};
+
+ struct IggyByteSizeVisitor;
+
+ impl<'de> Visitor<'de> for IggyByteSizeVisitor {
+ type Value = IggyByteSize;
+
+ fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
+ formatter
+ .write_str("a string like \"123KB\" or an unsigned integer representing bytes")
+ }
+
+ fn visit_u64<E>(self, value: u64) -> Result<IggyByteSize, E>
+ where
+ E: de::Error,
+ {
+ Ok(IggyByteSize::from(value))
+ }
+
+ fn visit_str<E>(self, value: &str) -> Result<IggyByteSize, E>
+ where
+ E: de::Error,
+ {
+ if let Ok(bytes) = value.parse::<u64>() {
+ return Ok(IggyByteSize::from(bytes));
+ }
+ Byte::from_str(value)
+ .map(IggyByteSize)
+ .map_err(|e| E::custom(format!("Failed to parse byte size: {}", e)))
+ }
+ }
+
+ deserializer.deserialize_any(IggyByteSizeVisitor)
+ }
+}
+
impl Default for IggyByteSize {
fn default() -> Self {
Self(Byte::from_u64(0))
diff --git a/core/connectors/runtime/Cargo.toml b/core/connectors/runtime/Cargo.toml
index ceee9bb6e..146543cce 100644
--- a/core/connectors/runtime/Cargo.toml
+++ b/core/connectors/runtime/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-connectors"
-version = "0.2.0"
+version = "0.2.0-edge.4"
description = "Connectors runtime for Iggy message streaming platform"
edition = "2024"
license = "Apache-2.0"
diff --git a/core/integration/tests/config_provider/mod.rs b/core/integration/tests/config_provider/mod.rs
index 5cdac19f4..882431747 100644
--- a/core/integration/tests/config_provider/mod.rs
+++ b/core/integration/tests/config_provider/mod.rs
@@ -69,13 +69,19 @@ async fn validate_config_env_override() {
#[serial]
#[tokio::test]
async fn validate_socket_override() {
- // Simulating env::set_var with "true" for the tests
- let expected_send_buffer = "666666";
- let expected_recv_buffer = "777777";
+ // Environment variables are set as raw byte counts
+ let send_buffer_bytes = 666666_u64;
+ let recv_buffer_bytes = 777777_u64;
unsafe {
env::set_var("IGGY_TCP_SOCKET_OVERRIDE_DEFAULTS", "true");
- env::set_var("IGGY_TCP_SOCKET_SEND_BUFFER_SIZE", expected_send_buffer);
- env::set_var("IGGY_TCP_SOCKET_RECV_BUFFER_SIZE", expected_recv_buffer);
+ env::set_var(
+ "IGGY_TCP_SOCKET_SEND_BUFFER_SIZE",
+ send_buffer_bytes.to_string(),
+ );
+ env::set_var(
+ "IGGY_TCP_SOCKET_RECV_BUFFER_SIZE",
+ recv_buffer_bytes.to_string(),
+ );
}
let config_path = get_root_path().join("../configs/server.toml");
@@ -86,13 +92,14 @@ async fn validate_socket_override() {
.expect("Failed to load server.toml config with socket override");
assert!(config.tcp.socket.override_defaults);
+ // Verify the buffer sizes match the expected byte counts
assert_eq!(
- config.tcp.socket.send_buffer_size.to_string(),
- expected_send_buffer
+ config.tcp.socket.send_buffer_size.as_bytes_u64(),
+ send_buffer_bytes
);
assert_eq!(
- config.tcp.socket.recv_buffer_size.to_string(),
- expected_recv_buffer
+ config.tcp.socket.recv_buffer_size.as_bytes_u64(),
+ recv_buffer_bytes
);
unsafe {
diff --git a/core/sdk/Cargo.toml b/core/sdk/Cargo.toml
index 484162223..812f8f1d1 100644
--- a/core/sdk/Cargo.toml
+++ b/core/sdk/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy"
-version = "0.8.0"
+version = "0.8.0-edge.6"
description = "Iggy is the persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second."
edition = "2024"
license = "Apache-2.0"
diff --git a/core/server/Cargo.toml b/core/server/Cargo.toml
index 6fa817948..e851e3fca 100644
--- a/core/server/Cargo.toml
+++ b/core/server/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "server"
-version = "0.6.0"
+version = "0.6.0-edge.6"
edition = "2024"
license = "Apache-2.0"
diff --git a/core/server/src/configs/config_provider.rs b/core/server/src/configs/config_provider.rs
index 260ab32ac..cbe9a3fa3 100644
--- a/core/server/src/configs/config_provider.rs
+++ b/core/server/src/configs/config_provider.rs
@@ -323,9 +323,6 @@ impl CustomEnvProvider {
if value == "false" {
return FigmentValue::from(false);
}
- if let Ok(int_val) = value.parse::<i64>() {
- return FigmentValue::from(int_val);
- }
if let Ok(float_val) = value.parse::<f64>() {
return FigmentValue::from(float_val);
}
diff --git a/foreign/csharp/Iggy_SDK/Iggy_SDK.csproj b/foreign/csharp/Iggy_SDK/Iggy_SDK.csproj
index d7a01cf0c..7fe0a5833 100644
--- a/foreign/csharp/Iggy_SDK/Iggy_SDK.csproj
+++ b/foreign/csharp/Iggy_SDK/Iggy_SDK.csproj
@@ -7,7 +7,7 @@
<TargetFramework>net8.0</TargetFramework>
<AssemblyName>Apache.Iggy</AssemblyName>
<RootNamespace>Apache.Iggy</RootNamespace>
- <PackageVersion>0.6.0</PackageVersion>
+ <PackageVersion>0.6.0-edge.5</PackageVersion>
<GenerateDocumentationFile>true</GenerateDocumentationFile>
</PropertyGroup>
diff --git a/foreign/java/gradle.properties b/foreign/java/gradle.properties
index ea001d5bf..7f8d985d2 100644
--- a/foreign/java/gradle.properties
+++ b/foreign/java/gradle.properties
@@ -1,2 +1,2 @@
-version=0.6.0
+version=0.6.0-SNAPSHOT
group=org.apache.iggy
diff --git a/foreign/node/package-lock.json b/foreign/node/package-lock.json
index fff48c83c..87689f327 100644
--- a/foreign/node/package-lock.json
+++ b/foreign/node/package-lock.json
@@ -1,6 +1,6 @@
{
"name": "apache-iggy",
- "version": "0.6.0",
+ "version": "0.6.0-edge.3",
"lockfileVersion": 3,
"requires": true,
"packages": {
diff --git a/foreign/node/package.json b/foreign/node/package.json
index 52d679e87..57ecbcc64 100644
--- a/foreign/node/package.json
+++ b/foreign/node/package.json
@@ -1,7 +1,7 @@
{
"name": "apache-iggy",
"type": "module",
- "version": "0.6.0",
+ "version": "0.6.0-edge.3",
"description": "Official Apache Iggy NodeJS SDK",
"keywords": [
"iggy",
diff --git a/foreign/python/Cargo.toml b/foreign/python/Cargo.toml
index 4714587f7..e695cea81 100644
--- a/foreign/python/Cargo.toml
+++ b/foreign/python/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "apache-iggy"
-version = "0.6.0"
+version = "0.6.0-dev2"
edition = "2021"
authors = ["Dario Lencina Talarico <da...@gmail.com>", "Albin Skott <al...@mattsson.io>"]
license = "Apache-2.0"
@@ -27,7 +27,7 @@ repository = "https://github.com/apache/iggy"
[dependencies]
bytes = "1.10.1"
-iggy = { path = "../../core/sdk", version = "0.8.0" }
+iggy = { path = "../../core/sdk", version = "0.8.0-edge.6" }
pyo3 = "0.26.0"
pyo3-async-runtimes = { version = "0.26.0", features = [
"attributes",
diff --git a/foreign/python/pyproject.toml b/foreign/python/pyproject.toml
index 6d918ab9a..a5828c936 100644
--- a/foreign/python/pyproject.toml
+++ b/foreign/python/pyproject.toml
@@ -22,7 +22,7 @@ build-backend = "maturin"
[project]
name = "apache-iggy"
requires-python = ">=3.7"
-version = "0.6.0"
+version = "0.6.0-dev2"
description = "Apache Iggy is the persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second."
readme = "README.md"
license = { file = "LICENSE" }
diff --git a/web/package.json b/web/package.json
index df3c3a53a..6b47f3217 100644
--- a/web/package.json
+++ b/web/package.json
@@ -1,6 +1,6 @@
{
"name": "iggy-web-ui",
- "version": "0.1.0",
+ "version": "0.1.0-edge.2",
"private": true,
"scripts": {
"dev": "vite dev --port 3050",