This is an automated email from the ASF dual-hosted git repository.
piotr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/master by this push:
new 1a2058b0 chore(sdk): refactor prelude package reference (#1783)
1a2058b0 is described below
commit 1a2058b0c8f2b9422b40ceaeb30da8986dc733e7
Author: Cancai Cai <[email protected]>
AuthorDate: Thu May 15 00:49:35 2025 +0800
chore(sdk): refactor prelude package reference (#1783)
---
core/bench/src/args/common.rs | 3 +--
core/bench/src/benchmarks/benchmark.rs | 6 +-----
core/bench/src/benchmarks/pinned_producer.rs | 3 +--
core/cli/src/args/topic.rs | 5 +----
core/cli/src/credentials.rs | 4 +---
core/cli/src/main.rs | 4 +---
core/integration/src/tcp_client.rs | 4 +---
core/integration/src/test_server.rs | 5 +----
.../tests/data_integrity/verify_after_server_restart.rs | 4 +---
core/integration/tests/examples/mod.rs | 7 +------
core/integration/tests/streaming/partition.rs | 4 +---
core/integration/tests/streaming/segment.rs | 5 -----
12 files changed, 11 insertions(+), 43 deletions(-)
diff --git a/core/bench/src/args/common.rs b/core/bench/src/args/common.rs
index b1964218..dec4ac3b 100644
--- a/core/bench/src/args/common.rs
+++ b/core/bench/src/args/common.rs
@@ -24,8 +24,7 @@ use bench_report::benchmark_kind::BenchmarkKind;
use bench_report::numeric_parameter::BenchmarkNumericParameter;
use clap::error::ErrorKind;
use clap::{CommandFactory, Parser};
-use iggy::prelude::IggyByteSize;
-use iggy::prelude::IggyDuration;
+use iggy::prelude::{IggyByteSize, IggyDuration};
use integration::test_server::Transport;
use std::net::SocketAddr;
use std::num::NonZeroU32;
diff --git a/core/bench/src/benchmarks/benchmark.rs
b/core/bench/src/benchmarks/benchmark.rs
index e7e2aa47..e14fd132 100644
--- a/core/bench/src/benchmarks/benchmark.rs
+++ b/core/bench/src/benchmarks/benchmark.rs
@@ -22,11 +22,7 @@ use async_trait::async_trait;
use bench_report::benchmark_kind::BenchmarkKind;
use bench_report::individual_metrics::BenchmarkIndividualMetrics;
use iggy::clients::client::IggyClient;
-use iggy::prelude::CompressionAlgorithm;
-use iggy::prelude::IggyError;
-use iggy::prelude::IggyExpiry;
-use iggy::prelude::MaxTopicSize;
-use iggy::prelude::{StreamClient, TopicClient};
+use iggy::prelude::*;
use integration::test_server::{ClientFactory, login_root};
use std::sync::Arc;
use tokio::task::JoinSet;
diff --git a/core/bench/src/benchmarks/pinned_producer.rs
b/core/bench/src/benchmarks/pinned_producer.rs
index d2b301a0..578819c8 100644
--- a/core/bench/src/benchmarks/pinned_producer.rs
+++ b/core/bench/src/benchmarks/pinned_producer.rs
@@ -22,8 +22,7 @@ use crate::benchmarks::common::*;
use async_trait::async_trait;
use bench_report::benchmark_kind::BenchmarkKind;
use bench_report::individual_metrics::BenchmarkIndividualMetrics;
-use iggy::prelude::IggyError;
-use iggy::prelude::MaxTopicSize;
+use iggy::prelude::{IggyError, MaxTopicSize};
use integration::test_server::ClientFactory;
use std::sync::Arc;
use tokio::task::JoinSet;
diff --git a/core/cli/src/args/topic.rs b/core/cli/src/args/topic.rs
index acd704a1..c753008b 100644
--- a/core/cli/src/args/topic.rs
+++ b/core/cli/src/args/topic.rs
@@ -18,10 +18,7 @@
use crate::args::common::ListMode;
use clap::{Args, Subcommand};
-use iggy::prelude::CompressionAlgorithm;
-use iggy::prelude::Identifier;
-use iggy::prelude::IggyExpiry;
-use iggy::prelude::MaxTopicSize;
+use iggy::prelude::{CompressionAlgorithm, Identifier, IggyExpiry,
MaxTopicSize};
#[derive(Debug, Clone, Subcommand)]
pub(crate) enum TopicAction {
diff --git a/core/cli/src/credentials.rs b/core/cli/src/credentials.rs
index 97089d7f..163916fa 100644
--- a/core/cli/src/credentials.rs
+++ b/core/cli/src/credentials.rs
@@ -20,9 +20,7 @@ use crate::args::CliOptions;
use crate::error::{CmdToolError, IggyCmdError};
use anyhow::{Context, bail};
use iggy::clients::client::IggyClient;
-use iggy::prelude::Args;
-use iggy::prelude::IggyError;
-use iggy::prelude::{PersonalAccessTokenClient, UserClient};
+use iggy::prelude::{Args, IggyError, PersonalAccessTokenClient, UserClient};
use iggy_binary_protocol::cli::binary_system::session::ServerSession;
use passterm::{Stream, isatty, prompt_password_stdin, prompt_password_tty};
use std::env::var;
diff --git a/core/cli/src/main.rs b/core/cli/src/main.rs
index 132a263b..8249c28a 100644
--- a/core/cli/src/main.rs
+++ b/core/cli/src/main.rs
@@ -38,9 +38,7 @@ use args::{CliOptions, IggyMergedConsoleArgs};
use clap::Parser;
use iggy::client_provider::{self, ClientProviderConfig};
use iggy::clients::client::IggyClient;
-use iggy::prelude::Args;
-use iggy::prelude::PersonalAccessTokenExpiry;
-use iggy::prelude::{Aes256GcmEncryptor, EncryptorKind};
+use iggy::prelude::{Aes256GcmEncryptor, Args, EncryptorKind,
PersonalAccessTokenExpiry};
use iggy_binary_protocol::cli::binary_context::common::ContextManager;
use iggy_binary_protocol::cli::binary_context::use_context::UseContextCmd;
use
iggy_binary_protocol::cli::binary_segments::delete_segments::DeleteSegmentsCmd;
diff --git a/core/integration/src/tcp_client.rs
b/core/integration/src/tcp_client.rs
index 64875ee8..35f4a894 100644
--- a/core/integration/src/tcp_client.rs
+++ b/core/integration/src/tcp_client.rs
@@ -18,9 +18,7 @@
use crate::test_server::ClientFactory;
use async_trait::async_trait;
-use iggy::prelude::Client;
-use iggy::prelude::TcpClient;
-use iggy::prelude::TcpClientConfig;
+use iggy::prelude::{Client, TcpClient, TcpClientConfig};
use std::sync::Arc;
#[derive(Debug, Clone, Default)]
diff --git a/core/integration/src/test_server.rs
b/core/integration/src/test_server.rs
index 30301310..605d0b8f 100644
--- a/core/integration/src/test_server.rs
+++ b/core/integration/src/test_server.rs
@@ -33,10 +33,7 @@ use futures::executor::block_on;
use uuid::Uuid;
use iggy::prelude::UserStatus::Active;
-use iggy::prelude::{
- Client, DEFAULT_ROOT_PASSWORD, DEFAULT_ROOT_USERNAME, StreamClient,
UserClient,
-};
-use iggy::prelude::{GlobalPermissions, Identifier, IdentityInfo, IggyClient,
Permissions};
+use iggy::prelude::*;
use server::configs::config_provider::{ConfigProvider, FileConfigProvider};
pub const SYSTEM_PATH_ENV_VAR: &str = "IGGY_SYSTEM_PATH";
diff --git
a/core/integration/tests/data_integrity/verify_after_server_restart.rs
b/core/integration/tests/data_integrity/verify_after_server_restart.rs
index becb53c3..8c11495b 100644
--- a/core/integration/tests/data_integrity/verify_after_server_restart.rs
+++ b/core/integration/tests/data_integrity/verify_after_server_restart.rs
@@ -18,9 +18,7 @@
use crate::bench::run_bench_and_wait_for_finish;
use iggy::clients::client::IggyClient;
-use iggy::prelude::Identifier;
-use iggy::prelude::IggyByteSize;
-use iggy::prelude::{MessageClient, SystemClient};
+use iggy::prelude::{Identifier, IggyByteSize, MessageClient, SystemClient};
use integration::{
tcp_client::TcpClientFactory,
test_server::{
diff --git a/core/integration/tests/examples/mod.rs
b/core/integration/tests/examples/mod.rs
index 10fb01c3..015eaa87 100644
--- a/core/integration/tests/examples/mod.rs
+++ b/core/integration/tests/examples/mod.rs
@@ -23,13 +23,8 @@ mod test_message_headers;
use assert_cmd::Command;
use iggy::clients::client::IggyClient;
-use iggy::prelude::CompressionAlgorithm;
-use iggy::prelude::IggyExpiry;
-use iggy::prelude::MaxTopicSize;
-use iggy::prelude::TcpClient;
-use iggy::prelude::TcpClientConfig;
use iggy::prelude::defaults::*;
-use iggy::prelude::{Client, StreamClient, SystemClient, TopicClient,
UserClient};
+use iggy::prelude::*;
use integration::test_server::{IpAddrKind, TestServer};
use regex::Regex;
use std::sync::Arc;
diff --git a/core/integration/tests/streaming/partition.rs
b/core/integration/tests/streaming/partition.rs
index 0a6c4a34..da91769d 100644
--- a/core/integration/tests/streaming/partition.rs
+++ b/core/integration/tests/streaming/partition.rs
@@ -18,9 +18,7 @@
use crate::streaming::common::test_setup::TestSetup;
use crate::streaming::create_messages;
-use iggy::prelude::IggyExpiry;
-use iggy::prelude::IggyTimestamp;
-use iggy::prelude::Sizeable;
+use iggy::prelude::{IggyExpiry, IggyTimestamp, Sizeable};
use server::state::system::PartitionState;
use server::streaming::partitions::partition::Partition;
use server::streaming::segments::*;
diff --git a/core/integration/tests/streaming/segment.rs
b/core/integration/tests/streaming/segment.rs
index 3a6390a7..42ce8158 100644
--- a/core/integration/tests/streaming/segment.rs
+++ b/core/integration/tests/streaming/segment.rs
@@ -19,11 +19,6 @@
use crate::streaming::common::test_setup::TestSetup;
use crate::streaming::create_message;
use bytes::Bytes;
-use iggy::prelude::CompressionAlgorithm;
-use iggy::prelude::Confirmation;
-use iggy::prelude::Identifier;
-use iggy::prelude::IggyError;
-use iggy::prelude::MaxTopicSize;
use iggy::prelude::locking::IggySharedMutFn;
use iggy::prelude::*;
use server::configs::server::{DataMaintenanceConfig,
PersonalAccessTokenConfig};
