This is an automated email from the ASF dual-hosted git repository. fresh-borzoni pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/fluss-rust.git
commit 9d682e38022be326b5c8d9ec5a6eeaed3edf5eb1 Author: Anton Borisov <[email protected]> AuthorDate: Fri Jun 19 23:33:40 2026 +0100 tighten pub visibility for protos --- crates/fluss/src/client/metadata.rs | 5 ++++- crates/fluss/src/lib.rs | 4 +++- crates/fluss/src/rpc/convert.rs | 9 ++++++--- crates/fluss/src/rpc/message/alter_cluster_configs.rs | 2 +- crates/fluss/src/rpc/message/alter_database.rs | 2 +- crates/fluss/src/rpc/message/alter_table.rs | 2 +- crates/fluss/src/rpc/message/api_versions.rs | 2 +- crates/fluss/src/rpc/message/authenticate.rs | 2 +- crates/fluss/src/rpc/message/create_acls.rs | 2 +- crates/fluss/src/rpc/message/create_database.rs | 2 +- crates/fluss/src/rpc/message/create_partition.rs | 2 +- crates/fluss/src/rpc/message/create_table.rs | 2 +- crates/fluss/src/rpc/message/database_exists.rs | 2 +- crates/fluss/src/rpc/message/describe_cluster_configs.rs | 2 +- crates/fluss/src/rpc/message/drop_acls.rs | 2 +- crates/fluss/src/rpc/message/drop_database.rs | 2 +- crates/fluss/src/rpc/message/drop_partition.rs | 2 +- crates/fluss/src/rpc/message/drop_table.rs | 2 +- crates/fluss/src/rpc/message/fetch.rs | 4 ++-- crates/fluss/src/rpc/message/get_database_info.rs | 2 +- crates/fluss/src/rpc/message/get_latest_lake_snapshot.rs | 2 +- crates/fluss/src/rpc/message/get_security_token.rs | 2 +- crates/fluss/src/rpc/message/get_table.rs | 2 +- crates/fluss/src/rpc/message/get_table_schema.rs | 2 +- crates/fluss/src/rpc/message/get_table_stats.rs | 2 +- crates/fluss/src/rpc/message/init_writer.rs | 4 ++-- crates/fluss/src/rpc/message/limit_scan.rs | 2 +- crates/fluss/src/rpc/message/list_acls.rs | 2 +- crates/fluss/src/rpc/message/list_database_summaries.rs | 2 +- crates/fluss/src/rpc/message/list_databases.rs | 2 +- crates/fluss/src/rpc/message/list_offsets.rs | 2 +- crates/fluss/src/rpc/message/list_partition_infos.rs | 2 +- crates/fluss/src/rpc/message/list_tables.rs | 2 +- crates/fluss/src/rpc/message/lookup.rs | 2 +- crates/fluss/src/rpc/message/prefix_lookup.rs | 2 +- crates/fluss/src/rpc/message/produce_log.rs | 2 +- crates/fluss/src/rpc/message/put_kv.rs | 2 +- crates/fluss/src/rpc/message/table_exists.rs | 2 +- crates/fluss/src/rpc/message/update_metadata.rs | 2 +- crates/fluss/src/rpc/mod.rs | 2 +- crates/fluss/src/rpc/server_connection.rs | 6 +++--- 41 files changed, 55 insertions(+), 47 deletions(-) diff --git a/crates/fluss/src/client/metadata.rs b/crates/fluss/src/client/metadata.rs index e27392f1..20a8a159 100644 --- a/crates/fluss/src/client/metadata.rs +++ b/crates/fluss/src/client/metadata.rs @@ -239,7 +239,10 @@ impl Metadata { Ok(self.get_cluster().get_partition_id(physical_table_path)) } - pub async fn get_connection(&self, server_node: &ServerNode) -> Result<ServerConnection> { + pub(crate) async fn get_connection( + &self, + server_node: &ServerNode, + ) -> Result<ServerConnection> { let result = self.connections.get_connection(server_node).await?; Ok(result) } diff --git a/crates/fluss/src/lib.rs b/crates/fluss/src/lib.rs index fab0d277..62d4c57d 100644 --- a/crates/fluss/src/lib.rs +++ b/crates/fluss/src/lib.rs @@ -146,6 +146,8 @@ pub type TableId = i64; pub type PartitionId = i64; pub type BucketId = i32; -pub mod proto { +pub(crate) mod proto { + // Generated; not every 1.x message is wired up to a caller yet. + #![allow(dead_code)] include!(concat!(env!("OUT_DIR"), "/proto.rs")); } diff --git a/crates/fluss/src/rpc/convert.rs b/crates/fluss/src/rpc/convert.rs index 441645c2..76a523db 100644 --- a/crates/fluss/src/rpc/convert.rs +++ b/crates/fluss/src/rpc/convert.rs @@ -19,14 +19,17 @@ use crate::cluster::{ServerNode, ServerType}; use crate::metadata::TablePath; use crate::proto::{PbServerNode, PbTablePath}; -pub fn to_table_path(table_path: &TablePath) -> PbTablePath { +pub(crate) fn to_table_path(table_path: &TablePath) -> PbTablePath { PbTablePath { database_name: table_path.database().to_string(), table_name: table_path.table().to_string(), } } -pub fn from_pb_server_node(pb_server_node: PbServerNode, server_type: ServerType) -> ServerNode { +pub(crate) fn from_pb_server_node( + pb_server_node: PbServerNode, + server_type: ServerType, +) -> ServerNode { ServerNode::new( pb_server_node.node_id, pb_server_node.host, @@ -35,7 +38,7 @@ pub fn from_pb_server_node(pb_server_node: PbServerNode, server_type: ServerType ) } -pub fn from_pb_table_path(pb_table_path: &PbTablePath) -> TablePath { +pub(crate) fn from_pb_table_path(pb_table_path: &PbTablePath) -> TablePath { TablePath::new( pb_table_path.database_name.to_string(), pb_table_path.table_name.to_string(), diff --git a/crates/fluss/src/rpc/message/alter_cluster_configs.rs b/crates/fluss/src/rpc/message/alter_cluster_configs.rs index fb8ced2d..6f14d261 100644 --- a/crates/fluss/src/rpc/message/alter_cluster_configs.rs +++ b/crates/fluss/src/rpc/message/alter_cluster_configs.rs @@ -25,7 +25,7 @@ use prost::Message; #[derive(Debug)] pub struct AlterClusterConfigsRequest { - pub inner_request: proto::AlterClusterConfigsRequest, + pub(crate) inner_request: proto::AlterClusterConfigsRequest, } impl AlterClusterConfigsRequest { diff --git a/crates/fluss/src/rpc/message/alter_database.rs b/crates/fluss/src/rpc/message/alter_database.rs index dc05f6ed..3eb08163 100644 --- a/crates/fluss/src/rpc/message/alter_database.rs +++ b/crates/fluss/src/rpc/message/alter_database.rs @@ -25,7 +25,7 @@ use prost::Message; #[derive(Debug)] pub struct AlterDatabaseRequest { - pub inner_request: proto::AlterDatabaseRequest, + pub(crate) inner_request: proto::AlterDatabaseRequest, } impl AlterDatabaseRequest { diff --git a/crates/fluss/src/rpc/message/alter_table.rs b/crates/fluss/src/rpc/message/alter_table.rs index 7cd59ae0..64e9ad09 100644 --- a/crates/fluss/src/rpc/message/alter_table.rs +++ b/crates/fluss/src/rpc/message/alter_table.rs @@ -26,7 +26,7 @@ use prost::Message; #[derive(Debug)] pub struct AlterTableRequest { - pub inner_request: proto::AlterTableRequest, + pub(crate) inner_request: proto::AlterTableRequest, } impl AlterTableRequest { diff --git a/crates/fluss/src/rpc/message/api_versions.rs b/crates/fluss/src/rpc/message/api_versions.rs index 579c66a7..42139a3a 100644 --- a/crates/fluss/src/rpc/message/api_versions.rs +++ b/crates/fluss/src/rpc/message/api_versions.rs @@ -27,7 +27,7 @@ use prost::Message; #[derive(Debug, Clone)] pub struct ApiVersionsRequest { - pub inner_request: ProtoApiVersionsRequest, + pub(crate) inner_request: ProtoApiVersionsRequest, } impl ApiVersionsRequest { diff --git a/crates/fluss/src/rpc/message/authenticate.rs b/crates/fluss/src/rpc/message/authenticate.rs index 1874b304..dca76256 100644 --- a/crates/fluss/src/rpc/message/authenticate.rs +++ b/crates/fluss/src/rpc/message/authenticate.rs @@ -25,7 +25,7 @@ use prost::Message; #[derive(Debug, Clone)] pub struct AuthenticateRequest { - pub inner_request: ProtoAuthenticateRequest, + pub(crate) inner_request: ProtoAuthenticateRequest, } impl AuthenticateRequest { diff --git a/crates/fluss/src/rpc/message/create_acls.rs b/crates/fluss/src/rpc/message/create_acls.rs index 658aa44d..011f76f2 100644 --- a/crates/fluss/src/rpc/message/create_acls.rs +++ b/crates/fluss/src/rpc/message/create_acls.rs @@ -25,7 +25,7 @@ use prost::Message; #[derive(Debug)] pub struct CreateAclsRequest { - pub inner_request: proto::CreateAclsRequest, + pub(crate) inner_request: proto::CreateAclsRequest, } impl CreateAclsRequest { diff --git a/crates/fluss/src/rpc/message/create_database.rs b/crates/fluss/src/rpc/message/create_database.rs index ed0868da..6fb982b1 100644 --- a/crates/fluss/src/rpc/message/create_database.rs +++ b/crates/fluss/src/rpc/message/create_database.rs @@ -30,7 +30,7 @@ use prost::Message; #[derive(Debug)] pub struct CreateDatabaseRequest { - pub inner_request: proto::CreateDatabaseRequest, + pub(crate) inner_request: proto::CreateDatabaseRequest, } impl CreateDatabaseRequest { diff --git a/crates/fluss/src/rpc/message/create_partition.rs b/crates/fluss/src/rpc/message/create_partition.rs index 1646f333..32dbced1 100644 --- a/crates/fluss/src/rpc/message/create_partition.rs +++ b/crates/fluss/src/rpc/message/create_partition.rs @@ -27,7 +27,7 @@ use prost::Message; #[derive(Debug)] pub struct CreatePartitionRequest { - pub inner_request: proto::CreatePartitionRequest, + pub(crate) inner_request: proto::CreatePartitionRequest, } impl CreatePartitionRequest { diff --git a/crates/fluss/src/rpc/message/create_table.rs b/crates/fluss/src/rpc/message/create_table.rs index 4647fec6..3189c14f 100644 --- a/crates/fluss/src/rpc/message/create_table.rs +++ b/crates/fluss/src/rpc/message/create_table.rs @@ -31,7 +31,7 @@ use prost::Message; #[derive(Debug)] pub struct CreateTableRequest { - pub inner_request: proto::CreateTableRequest, + pub(crate) inner_request: proto::CreateTableRequest, } impl CreateTableRequest { diff --git a/crates/fluss/src/rpc/message/database_exists.rs b/crates/fluss/src/rpc/message/database_exists.rs index 4a9588a2..296d1560 100644 --- a/crates/fluss/src/rpc/message/database_exists.rs +++ b/crates/fluss/src/rpc/message/database_exists.rs @@ -26,7 +26,7 @@ use prost::Message; #[derive(Debug)] pub struct DatabaseExistsRequest { - pub inner_request: proto::DatabaseExistsRequest, + pub(crate) inner_request: proto::DatabaseExistsRequest, } impl DatabaseExistsRequest { diff --git a/crates/fluss/src/rpc/message/describe_cluster_configs.rs b/crates/fluss/src/rpc/message/describe_cluster_configs.rs index d085b3e6..8e6ea4e2 100644 --- a/crates/fluss/src/rpc/message/describe_cluster_configs.rs +++ b/crates/fluss/src/rpc/message/describe_cluster_configs.rs @@ -24,7 +24,7 @@ use prost::Message; #[derive(Debug, Default)] pub struct DescribeClusterConfigsRequest { - pub inner_request: proto::DescribeClusterConfigsRequest, + pub(crate) inner_request: proto::DescribeClusterConfigsRequest, } impl DescribeClusterConfigsRequest { diff --git a/crates/fluss/src/rpc/message/drop_acls.rs b/crates/fluss/src/rpc/message/drop_acls.rs index cad27e7b..47068108 100644 --- a/crates/fluss/src/rpc/message/drop_acls.rs +++ b/crates/fluss/src/rpc/message/drop_acls.rs @@ -25,7 +25,7 @@ use prost::Message; #[derive(Debug)] pub struct DropAclsRequest { - pub inner_request: proto::DropAclsRequest, + pub(crate) inner_request: proto::DropAclsRequest, } impl DropAclsRequest { diff --git a/crates/fluss/src/rpc/message/drop_database.rs b/crates/fluss/src/rpc/message/drop_database.rs index bf7477f3..8a777dfd 100644 --- a/crates/fluss/src/rpc/message/drop_database.rs +++ b/crates/fluss/src/rpc/message/drop_database.rs @@ -26,7 +26,7 @@ use prost::Message; #[derive(Debug)] pub struct DropDatabaseRequest { - pub inner_request: proto::DropDatabaseRequest, + pub(crate) inner_request: proto::DropDatabaseRequest, } impl DropDatabaseRequest { diff --git a/crates/fluss/src/rpc/message/drop_partition.rs b/crates/fluss/src/rpc/message/drop_partition.rs index c7494acb..699c4562 100644 --- a/crates/fluss/src/rpc/message/drop_partition.rs +++ b/crates/fluss/src/rpc/message/drop_partition.rs @@ -27,7 +27,7 @@ use prost::Message; #[derive(Debug)] pub struct DropPartitionRequest { - pub inner_request: proto::DropPartitionRequest, + pub(crate) inner_request: proto::DropPartitionRequest, } impl DropPartitionRequest { diff --git a/crates/fluss/src/rpc/message/drop_table.rs b/crates/fluss/src/rpc/message/drop_table.rs index b452cf07..fcc9c2e4 100644 --- a/crates/fluss/src/rpc/message/drop_table.rs +++ b/crates/fluss/src/rpc/message/drop_table.rs @@ -31,7 +31,7 @@ use prost::Message; #[derive(Debug)] pub struct DropTableRequest { - pub inner_request: proto::DropTableRequest, + pub(crate) inner_request: proto::DropTableRequest, } impl DropTableRequest { diff --git a/crates/fluss/src/rpc/message/fetch.rs b/crates/fluss/src/rpc/message/fetch.rs index 67930f84..ed6a6a4d 100644 --- a/crates/fluss/src/rpc/message/fetch.rs +++ b/crates/fluss/src/rpc/message/fetch.rs @@ -34,11 +34,11 @@ const LOG_FETCH_MIN_BYTES: i32 = 1; const LOG_FETCH_WAIT_MAX_TIME: i32 = 500; pub struct FetchLogRequest { - pub inner_request: proto::FetchLogRequest, + pub(crate) inner_request: proto::FetchLogRequest, } impl FetchLogRequest { - pub fn new(fetch_log_request: proto::FetchLogRequest) -> Self { + pub(crate) fn new(fetch_log_request: proto::FetchLogRequest) -> Self { Self { inner_request: fetch_log_request, } diff --git a/crates/fluss/src/rpc/message/get_database_info.rs b/crates/fluss/src/rpc/message/get_database_info.rs index 63647d52..35b0eb22 100644 --- a/crates/fluss/src/rpc/message/get_database_info.rs +++ b/crates/fluss/src/rpc/message/get_database_info.rs @@ -26,7 +26,7 @@ use prost::Message; #[derive(Debug)] pub struct GetDatabaseInfoRequest { - pub inner_request: proto::GetDatabaseInfoRequest, + pub(crate) inner_request: proto::GetDatabaseInfoRequest, } impl GetDatabaseInfoRequest { diff --git a/crates/fluss/src/rpc/message/get_latest_lake_snapshot.rs b/crates/fluss/src/rpc/message/get_latest_lake_snapshot.rs index a23a985d..75f70349 100644 --- a/crates/fluss/src/rpc/message/get_latest_lake_snapshot.rs +++ b/crates/fluss/src/rpc/message/get_latest_lake_snapshot.rs @@ -30,7 +30,7 @@ use prost::Message; #[derive(Debug)] pub struct GetLatestLakeSnapshotRequest { - pub inner_request: proto::GetLatestLakeSnapshotRequest, + pub(crate) inner_request: proto::GetLatestLakeSnapshotRequest, } impl GetLatestLakeSnapshotRequest { diff --git a/crates/fluss/src/rpc/message/get_security_token.rs b/crates/fluss/src/rpc/message/get_security_token.rs index 741c8482..2c825ac3 100644 --- a/crates/fluss/src/rpc/message/get_security_token.rs +++ b/crates/fluss/src/rpc/message/get_security_token.rs @@ -25,7 +25,7 @@ use prost::Message; #[derive(Debug)] pub struct GetSecurityTokenRequest { - pub inner_request: GetFileSystemSecurityTokenRequest, + pub(crate) inner_request: GetFileSystemSecurityTokenRequest, } impl GetSecurityTokenRequest { diff --git a/crates/fluss/src/rpc/message/get_table.rs b/crates/fluss/src/rpc/message/get_table.rs index a7562f92..6165e8d7 100644 --- a/crates/fluss/src/rpc/message/get_table.rs +++ b/crates/fluss/src/rpc/message/get_table.rs @@ -29,7 +29,7 @@ use prost::Message; #[derive(Debug)] pub struct GetTableRequest { - pub inner_request: GetTableInfoRequest, + pub(crate) inner_request: GetTableInfoRequest, } impl GetTableRequest { diff --git a/crates/fluss/src/rpc/message/get_table_schema.rs b/crates/fluss/src/rpc/message/get_table_schema.rs index 1c7c00b7..cd2f20ad 100644 --- a/crates/fluss/src/rpc/message/get_table_schema.rs +++ b/crates/fluss/src/rpc/message/get_table_schema.rs @@ -30,7 +30,7 @@ use prost::Message; /// `schema_id = None` requests the latest schema. #[derive(Debug)] pub struct GetTableSchemaRequestMsg { - pub inner_request: GetTableSchemaRequest, + pub(crate) inner_request: GetTableSchemaRequest, } impl GetTableSchemaRequestMsg { diff --git a/crates/fluss/src/rpc/message/get_table_stats.rs b/crates/fluss/src/rpc/message/get_table_stats.rs index e8ea1165..c5ef610a 100644 --- a/crates/fluss/src/rpc/message/get_table_stats.rs +++ b/crates/fluss/src/rpc/message/get_table_stats.rs @@ -25,7 +25,7 @@ use prost::Message; #[derive(Debug)] pub struct GetTableStatsRequest { - pub inner_request: proto::GetTableStatsRequest, + pub(crate) inner_request: proto::GetTableStatsRequest, } impl GetTableStatsRequest { diff --git a/crates/fluss/src/rpc/message/init_writer.rs b/crates/fluss/src/rpc/message/init_writer.rs index b2e64a5f..ec30de5d 100644 --- a/crates/fluss/src/rpc/message/init_writer.rs +++ b/crates/fluss/src/rpc/message/init_writer.rs @@ -24,11 +24,11 @@ use bytes::{Buf, BufMut}; use prost::Message; pub struct InitWriterRequest { - pub inner_request: proto::InitWriterRequest, + pub(crate) inner_request: proto::InitWriterRequest, } impl InitWriterRequest { - pub fn new(table_paths: Vec<PbTablePath>) -> Self { + pub(crate) fn new(table_paths: Vec<PbTablePath>) -> Self { InitWriterRequest { inner_request: proto::InitWriterRequest { table_path: table_paths, diff --git a/crates/fluss/src/rpc/message/limit_scan.rs b/crates/fluss/src/rpc/message/limit_scan.rs index c71b03c3..cf9a0363 100644 --- a/crates/fluss/src/rpc/message/limit_scan.rs +++ b/crates/fluss/src/rpc/message/limit_scan.rs @@ -27,7 +27,7 @@ use prost::Message; use bytes::{Buf, BufMut}; pub struct LimitScanRequest { - pub inner_request: proto::LimitScanRequest, + pub(crate) inner_request: proto::LimitScanRequest, } impl LimitScanRequest { diff --git a/crates/fluss/src/rpc/message/list_acls.rs b/crates/fluss/src/rpc/message/list_acls.rs index 68c1177c..1b4bdc9f 100644 --- a/crates/fluss/src/rpc/message/list_acls.rs +++ b/crates/fluss/src/rpc/message/list_acls.rs @@ -25,7 +25,7 @@ use prost::Message; #[derive(Debug)] pub struct ListAclsRequest { - pub inner_request: proto::ListAclsRequest, + pub(crate) inner_request: proto::ListAclsRequest, } impl ListAclsRequest { diff --git a/crates/fluss/src/rpc/message/list_database_summaries.rs b/crates/fluss/src/rpc/message/list_database_summaries.rs index 406233fc..6acea72f 100644 --- a/crates/fluss/src/rpc/message/list_database_summaries.rs +++ b/crates/fluss/src/rpc/message/list_database_summaries.rs @@ -24,7 +24,7 @@ use prost::Message; #[derive(Debug, Default)] pub struct ListDatabaseSummariesRequest { - pub inner_request: proto::ListDatabasesRequest, + pub(crate) inner_request: proto::ListDatabasesRequest, } impl ListDatabaseSummariesRequest { diff --git a/crates/fluss/src/rpc/message/list_databases.rs b/crates/fluss/src/rpc/message/list_databases.rs index 74ca4944..064a1e94 100644 --- a/crates/fluss/src/rpc/message/list_databases.rs +++ b/crates/fluss/src/rpc/message/list_databases.rs @@ -26,7 +26,7 @@ use prost::Message; #[derive(Debug, Default)] pub struct ListDatabasesRequest { - pub inner_request: proto::ListDatabasesRequest, + pub(crate) inner_request: proto::ListDatabasesRequest, } impl ListDatabasesRequest { diff --git a/crates/fluss/src/rpc/message/list_offsets.rs b/crates/fluss/src/rpc/message/list_offsets.rs index 2ec14370..a690b82e 100644 --- a/crates/fluss/src/rpc/message/list_offsets.rs +++ b/crates/fluss/src/rpc/message/list_offsets.rs @@ -68,7 +68,7 @@ impl OffsetSpec { #[derive(Debug)] pub struct ListOffsetsRequest { - pub inner_request: proto::ListOffsetsRequest, + pub(crate) inner_request: proto::ListOffsetsRequest, } impl ListOffsetsRequest { diff --git a/crates/fluss/src/rpc/message/list_partition_infos.rs b/crates/fluss/src/rpc/message/list_partition_infos.rs index cf24f466..091af6da 100644 --- a/crates/fluss/src/rpc/message/list_partition_infos.rs +++ b/crates/fluss/src/rpc/message/list_partition_infos.rs @@ -27,7 +27,7 @@ use prost::Message; #[derive(Debug)] pub struct ListPartitionInfosRequest { - pub inner_request: proto::ListPartitionInfosRequest, + pub(crate) inner_request: proto::ListPartitionInfosRequest, } impl ListPartitionInfosRequest { diff --git a/crates/fluss/src/rpc/message/list_tables.rs b/crates/fluss/src/rpc/message/list_tables.rs index 8ff72141..126c8001 100644 --- a/crates/fluss/src/rpc/message/list_tables.rs +++ b/crates/fluss/src/rpc/message/list_tables.rs @@ -29,7 +29,7 @@ use prost::Message; #[derive(Debug)] pub struct ListTablesRequest { - pub inner_request: proto::ListTablesRequest, + pub(crate) inner_request: proto::ListTablesRequest, } impl ListTablesRequest { diff --git a/crates/fluss/src/rpc/message/lookup.rs b/crates/fluss/src/rpc/message/lookup.rs index e205fa6b..2f058cde 100644 --- a/crates/fluss/src/rpc/message/lookup.rs +++ b/crates/fluss/src/rpc/message/lookup.rs @@ -28,7 +28,7 @@ use prost::Message; use bytes::{Buf, BufMut}; pub struct LookupRequest { - pub inner_request: proto::LookupRequest, + pub(crate) inner_request: proto::LookupRequest, } impl LookupRequest { diff --git a/crates/fluss/src/rpc/message/prefix_lookup.rs b/crates/fluss/src/rpc/message/prefix_lookup.rs index e71ffe7c..afafbbf7 100644 --- a/crates/fluss/src/rpc/message/prefix_lookup.rs +++ b/crates/fluss/src/rpc/message/prefix_lookup.rs @@ -28,7 +28,7 @@ use prost::Message; use bytes::{Buf, BufMut}; pub struct PrefixLookupRequest { - pub inner_request: proto::PrefixLookupRequest, + pub(crate) inner_request: proto::PrefixLookupRequest, } impl PrefixLookupRequest { diff --git a/crates/fluss/src/rpc/message/produce_log.rs b/crates/fluss/src/rpc/message/produce_log.rs index 8be24638..dc3acb72 100644 --- a/crates/fluss/src/rpc/message/produce_log.rs +++ b/crates/fluss/src/rpc/message/produce_log.rs @@ -28,7 +28,7 @@ use bytes::{Buf, BufMut}; use prost::Message; pub struct ProduceLogRequest { - pub inner_request: proto::ProduceLogRequest, + pub(crate) inner_request: proto::ProduceLogRequest, } impl ProduceLogRequest { diff --git a/crates/fluss/src/rpc/message/put_kv.rs b/crates/fluss/src/rpc/message/put_kv.rs index e76496d1..d9f2ad3f 100644 --- a/crates/fluss/src/rpc/message/put_kv.rs +++ b/crates/fluss/src/rpc/message/put_kv.rs @@ -27,7 +27,7 @@ use prost::Message; #[allow(dead_code)] pub struct PutKvRequest { - pub inner_request: proto::PutKvRequest, + pub(crate) inner_request: proto::PutKvRequest, } #[allow(dead_code)] diff --git a/crates/fluss/src/rpc/message/table_exists.rs b/crates/fluss/src/rpc/message/table_exists.rs index 5bc848e3..95bee24a 100644 --- a/crates/fluss/src/rpc/message/table_exists.rs +++ b/crates/fluss/src/rpc/message/table_exists.rs @@ -30,7 +30,7 @@ use bytes::{Buf, BufMut}; use prost::Message; #[derive(Debug)] pub struct TableExistsRequest { - pub inner_request: proto::TableExistsRequest, + pub(crate) inner_request: proto::TableExistsRequest, } impl TableExistsRequest { diff --git a/crates/fluss/src/rpc/message/update_metadata.rs b/crates/fluss/src/rpc/message/update_metadata.rs index fd96ca5e..797fd4a0 100644 --- a/crates/fluss/src/rpc/message/update_metadata.rs +++ b/crates/fluss/src/rpc/message/update_metadata.rs @@ -29,7 +29,7 @@ use bytes::{Buf, BufMut}; use prost::Message; pub struct UpdateMetadataRequest { - pub inner_request: proto::MetadataRequest, + pub(crate) inner_request: proto::MetadataRequest, } impl UpdateMetadataRequest { diff --git a/crates/fluss/src/rpc/mod.rs b/crates/fluss/src/rpc/mod.rs index 6f3a88d1..a4b191d8 100644 --- a/crates/fluss/src/rpc/mod.rs +++ b/crates/fluss/src/rpc/mod.rs @@ -29,4 +29,4 @@ pub use server_connection::*; mod convert; mod transport; -pub use convert::*; +pub(crate) use convert::*; diff --git a/crates/fluss/src/rpc/server_connection.rs b/crates/fluss/src/rpc/server_connection.rs index a1ea4657..a40fd58d 100644 --- a/crates/fluss/src/rpc/server_connection.rs +++ b/crates/fluss/src/rpc/server_connection.rs @@ -85,7 +85,7 @@ pub struct ServerApiVersions { impl ServerApiVersions { /// Build from the server's advertised API version list. - pub fn new(server_versions: &[PbApiVersion]) -> Self { + pub(crate) fn new(server_versions: &[PbApiVersion]) -> Self { let mut versions = HashMap::new(); for sv in server_versions { let api_key = ApiKey::from(i16::try_from(sv.api_key).unwrap()); @@ -207,7 +207,7 @@ impl RpcClient { self } - pub async fn get_connection( + pub(crate) async fn get_connection( &self, server_node: &ServerNode, ) -> Result<ServerConnection, Error> { @@ -534,7 +534,7 @@ where matches!(*guard, ConnectionState::Poison(_)) } - pub async fn request<R>(&self, msg: R) -> Result<R::ResponseBody, Error> + pub(crate) async fn request<R>(&self, msg: R) -> Result<R::ResponseBody, Error> where R: RequestBody + Send + WriteType<Vec<u8>>, R::ResponseBody: ReadType<Cursor<Vec<u8>>>,
