Skip to content

Commit 4afa57d

Browse files
author
Yinwei Li
committed
Use cargo fmt to format the code
Signed-off-by: Yinwei Li <yinwei.li@zilliz.com>
1 parent 05530dd commit 4afa57d

23 files changed

+1396
-2002
lines changed

examples/query_search.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,6 @@ async fn prepare_data(client: &Client) -> Result<()> {
164164
Ok(())
165165
}
166166

167-
168167
// Print functions.
169168
// You can ignore this part.
170169

src/collection.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -751,7 +751,7 @@ pub type ParamValue = serde_json::Value;
751751
pub use serde_json::json as ParamValue;
752752

753753
// search result for a single vector
754-
#[derive(Clone,Debug)]
754+
#[derive(Clone, Debug)]
755755
pub struct SearchResult<'a> {
756756
pub size: i64,
757757
pub id: Vec<Value<'a>>,

src/index/mod.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ impl IndexParams {
119119

120120
#[derive(Debug, Clone)]
121121
pub struct IndexInfo {
122-
index_name:String,
122+
index_name: String,
123123
field_name: String,
124124
id: i64,
125125
params: IndexParams,
@@ -143,7 +143,7 @@ impl IndexInfo {
143143
self.state
144144
}
145145

146-
pub fn index_name(&self)->&str {
146+
pub fn index_name(&self) -> &str {
147147
&self.index_name
148148
}
149149
}
@@ -168,7 +168,7 @@ impl From<IndexDescription> for IndexInfo {
168168
params,
169169
);
170170
Self {
171-
index_name:description.index_name.clone(),
171+
index_name: description.index_name.clone(),
172172
field_name: description.field_name.clone(),
173173
id: description.index_id,
174174
params: params,

src/index/utils.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ use crate::{config, proto};
2121
use std::time::Duration;
2222

2323
impl Client {
24-
2524
async fn create_index_impl<S>(
2625
&self,
2726
collection_name: S,
@@ -157,7 +156,7 @@ impl Client {
157156
db_name: "".to_string(),
158157
collection_name: collection_name.into(),
159158
field_name: "".to_string(),
160-
index_name: index_name.into()
159+
index_name: index_name.into(),
161160
})
162161
.await?
163162
.into_inner();

src/lib.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,20 +14,20 @@
1414
// See the License for the specific language governing permissions and
1515
// limitations under the License.
1616

17+
pub mod authentication;
1718
pub mod client;
1819
pub mod collection;
1920
pub mod data;
21+
pub mod database;
2022
pub mod error;
23+
pub mod iterator;
2124
pub mod mutate;
2225
pub mod options;
2326
pub mod partition;
2427
pub mod query;
28+
pub mod resource_group;
2529
pub mod schema;
2630
pub mod value;
27-
pub mod iterator;
28-
pub mod database;
29-
pub mod resource_group;
30-
pub mod authentication;
3131

3232
mod config;
3333
pub mod index;

src/proto/milvus.proto.common.rs

Lines changed: 27 additions & 73 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,8 @@ pub struct Status {
1414
#[prost(string, tag = "5")]
1515
pub detail: ::prost::alloc::string::String,
1616
#[prost(map = "string, string", tag = "6")]
17-
pub extra_info: ::std::collections::HashMap<
18-
::prost::alloc::string::String,
19-
::prost::alloc::string::String,
20-
>,
17+
pub extra_info:
18+
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
2119
}
2220
#[allow(clippy::derive_partial_eq_without_eq)]
2321
#[derive(Clone, PartialEq, ::prost::Message)]
@@ -82,10 +80,8 @@ pub struct MsgBase {
8280
#[prost(int64, tag = "5")]
8381
pub target_id: i64,
8482
#[prost(map = "string, string", tag = "6")]
85-
pub properties: ::std::collections::HashMap<
86-
::prost::alloc::string::String,
87-
::prost::alloc::string::String,
88-
>,
83+
pub properties:
84+
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
8985
#[prost(message, optional, tag = "7")]
9086
pub replicate_info: ::core::option::Option<ReplicateInfo>,
9187
}
@@ -152,10 +148,8 @@ pub struct ClientInfo {
152148
pub host: ::prost::alloc::string::String,
153149
/// reserved for newly-added feature if necessary.
154150
#[prost(map = "string, string", tag = "6")]
155-
pub reserved: ::std::collections::HashMap<
156-
::prost::alloc::string::String,
157-
::prost::alloc::string::String,
158-
>,
151+
pub reserved:
152+
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
159153
}
160154
#[allow(clippy::derive_partial_eq_without_eq)]
161155
#[derive(Clone, PartialEq, ::prost::Message)]
@@ -172,10 +166,8 @@ pub struct ServerInfo {
172166
pub deploy_mode: ::prost::alloc::string::String,
173167
/// reserved for newly-added feature if necessary.
174168
#[prost(map = "string, string", tag = "6")]
175-
pub reserved: ::std::collections::HashMap<
176-
::prost::alloc::string::String,
177-
::prost::alloc::string::String,
178-
>,
169+
pub reserved:
170+
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
179171
}
180172
/// NodeInfo is used to describe the node information.
181173
#[allow(clippy::derive_partial_eq_without_eq)]
@@ -1226,13 +1218,9 @@ impl ObjectPrivilege {
12261218
ObjectPrivilege::PrivilegeManageOwnership => "PrivilegeManageOwnership",
12271219
ObjectPrivilege::PrivilegeSelectUser => "PrivilegeSelectUser",
12281220
ObjectPrivilege::PrivilegeUpsert => "PrivilegeUpsert",
1229-
ObjectPrivilege::PrivilegeCreateResourceGroup => {
1230-
"PrivilegeCreateResourceGroup"
1231-
}
1221+
ObjectPrivilege::PrivilegeCreateResourceGroup => "PrivilegeCreateResourceGroup",
12321222
ObjectPrivilege::PrivilegeDropResourceGroup => "PrivilegeDropResourceGroup",
1233-
ObjectPrivilege::PrivilegeDescribeResourceGroup => {
1234-
"PrivilegeDescribeResourceGroup"
1235-
}
1223+
ObjectPrivilege::PrivilegeDescribeResourceGroup => "PrivilegeDescribeResourceGroup",
12361224
ObjectPrivilege::PrivilegeListResourceGroups => "PrivilegeListResourceGroups",
12371225
ObjectPrivilege::PrivilegeTransferNode => "PrivilegeTransferNode",
12381226
ObjectPrivilege::PrivilegeTransferReplica => "PrivilegeTransferReplica",
@@ -1252,49 +1240,29 @@ impl ObjectPrivilege {
12521240
ObjectPrivilege::PrivilegeDropAlias => "PrivilegeDropAlias",
12531241
ObjectPrivilege::PrivilegeDescribeAlias => "PrivilegeDescribeAlias",
12541242
ObjectPrivilege::PrivilegeListAliases => "PrivilegeListAliases",
1255-
ObjectPrivilege::PrivilegeUpdateResourceGroups => {
1256-
"PrivilegeUpdateResourceGroups"
1257-
}
1243+
ObjectPrivilege::PrivilegeUpdateResourceGroups => "PrivilegeUpdateResourceGroups",
12581244
ObjectPrivilege::PrivilegeAlterDatabase => "PrivilegeAlterDatabase",
12591245
ObjectPrivilege::PrivilegeDescribeDatabase => "PrivilegeDescribeDatabase",
12601246
ObjectPrivilege::PrivilegeBackupRbac => "PrivilegeBackupRBAC",
12611247
ObjectPrivilege::PrivilegeRestoreRbac => "PrivilegeRestoreRBAC",
12621248
ObjectPrivilege::PrivilegeGroupReadOnly => "PrivilegeGroupReadOnly",
12631249
ObjectPrivilege::PrivilegeGroupReadWrite => "PrivilegeGroupReadWrite",
12641250
ObjectPrivilege::PrivilegeGroupAdmin => "PrivilegeGroupAdmin",
1265-
ObjectPrivilege::PrivilegeCreatePrivilegeGroup => {
1266-
"PrivilegeCreatePrivilegeGroup"
1267-
}
1251+
ObjectPrivilege::PrivilegeCreatePrivilegeGroup => "PrivilegeCreatePrivilegeGroup",
12681252
ObjectPrivilege::PrivilegeDropPrivilegeGroup => "PrivilegeDropPrivilegeGroup",
1269-
ObjectPrivilege::PrivilegeListPrivilegeGroups => {
1270-
"PrivilegeListPrivilegeGroups"
1271-
}
1272-
ObjectPrivilege::PrivilegeOperatePrivilegeGroup => {
1273-
"PrivilegeOperatePrivilegeGroup"
1274-
}
1275-
ObjectPrivilege::PrivilegeGroupClusterReadOnly => {
1276-
"PrivilegeGroupClusterReadOnly"
1277-
}
1278-
ObjectPrivilege::PrivilegeGroupClusterReadWrite => {
1279-
"PrivilegeGroupClusterReadWrite"
1280-
}
1253+
ObjectPrivilege::PrivilegeListPrivilegeGroups => "PrivilegeListPrivilegeGroups",
1254+
ObjectPrivilege::PrivilegeOperatePrivilegeGroup => "PrivilegeOperatePrivilegeGroup",
1255+
ObjectPrivilege::PrivilegeGroupClusterReadOnly => "PrivilegeGroupClusterReadOnly",
1256+
ObjectPrivilege::PrivilegeGroupClusterReadWrite => "PrivilegeGroupClusterReadWrite",
12811257
ObjectPrivilege::PrivilegeGroupClusterAdmin => "PrivilegeGroupClusterAdmin",
1282-
ObjectPrivilege::PrivilegeGroupDatabaseReadOnly => {
1283-
"PrivilegeGroupDatabaseReadOnly"
1284-
}
1285-
ObjectPrivilege::PrivilegeGroupDatabaseReadWrite => {
1286-
"PrivilegeGroupDatabaseReadWrite"
1287-
}
1258+
ObjectPrivilege::PrivilegeGroupDatabaseReadOnly => "PrivilegeGroupDatabaseReadOnly",
1259+
ObjectPrivilege::PrivilegeGroupDatabaseReadWrite => "PrivilegeGroupDatabaseReadWrite",
12881260
ObjectPrivilege::PrivilegeGroupDatabaseAdmin => "PrivilegeGroupDatabaseAdmin",
1289-
ObjectPrivilege::PrivilegeGroupCollectionReadOnly => {
1290-
"PrivilegeGroupCollectionReadOnly"
1291-
}
1261+
ObjectPrivilege::PrivilegeGroupCollectionReadOnly => "PrivilegeGroupCollectionReadOnly",
12921262
ObjectPrivilege::PrivilegeGroupCollectionReadWrite => {
12931263
"PrivilegeGroupCollectionReadWrite"
12941264
}
1295-
ObjectPrivilege::PrivilegeGroupCollectionAdmin => {
1296-
"PrivilegeGroupCollectionAdmin"
1297-
}
1265+
ObjectPrivilege::PrivilegeGroupCollectionAdmin => "PrivilegeGroupCollectionAdmin",
12981266
}
12991267
}
13001268
/// Creates an enum from field names used in the ProtoBuf definition.
@@ -1328,9 +1296,7 @@ impl ObjectPrivilege {
13281296
"PrivilegeUpsert" => Some(Self::PrivilegeUpsert),
13291297
"PrivilegeCreateResourceGroup" => Some(Self::PrivilegeCreateResourceGroup),
13301298
"PrivilegeDropResourceGroup" => Some(Self::PrivilegeDropResourceGroup),
1331-
"PrivilegeDescribeResourceGroup" => {
1332-
Some(Self::PrivilegeDescribeResourceGroup)
1333-
}
1299+
"PrivilegeDescribeResourceGroup" => Some(Self::PrivilegeDescribeResourceGroup),
13341300
"PrivilegeListResourceGroups" => Some(Self::PrivilegeListResourceGroups),
13351301
"PrivilegeTransferNode" => Some(Self::PrivilegeTransferNode),
13361302
"PrivilegeTransferReplica" => Some(Self::PrivilegeTransferReplica),
@@ -1361,27 +1327,15 @@ impl ObjectPrivilege {
13611327
"PrivilegeCreatePrivilegeGroup" => Some(Self::PrivilegeCreatePrivilegeGroup),
13621328
"PrivilegeDropPrivilegeGroup" => Some(Self::PrivilegeDropPrivilegeGroup),
13631329
"PrivilegeListPrivilegeGroups" => Some(Self::PrivilegeListPrivilegeGroups),
1364-
"PrivilegeOperatePrivilegeGroup" => {
1365-
Some(Self::PrivilegeOperatePrivilegeGroup)
1366-
}
1330+
"PrivilegeOperatePrivilegeGroup" => Some(Self::PrivilegeOperatePrivilegeGroup),
13671331
"PrivilegeGroupClusterReadOnly" => Some(Self::PrivilegeGroupClusterReadOnly),
1368-
"PrivilegeGroupClusterReadWrite" => {
1369-
Some(Self::PrivilegeGroupClusterReadWrite)
1370-
}
1332+
"PrivilegeGroupClusterReadWrite" => Some(Self::PrivilegeGroupClusterReadWrite),
13711333
"PrivilegeGroupClusterAdmin" => Some(Self::PrivilegeGroupClusterAdmin),
1372-
"PrivilegeGroupDatabaseReadOnly" => {
1373-
Some(Self::PrivilegeGroupDatabaseReadOnly)
1374-
}
1375-
"PrivilegeGroupDatabaseReadWrite" => {
1376-
Some(Self::PrivilegeGroupDatabaseReadWrite)
1377-
}
1334+
"PrivilegeGroupDatabaseReadOnly" => Some(Self::PrivilegeGroupDatabaseReadOnly),
1335+
"PrivilegeGroupDatabaseReadWrite" => Some(Self::PrivilegeGroupDatabaseReadWrite),
13781336
"PrivilegeGroupDatabaseAdmin" => Some(Self::PrivilegeGroupDatabaseAdmin),
1379-
"PrivilegeGroupCollectionReadOnly" => {
1380-
Some(Self::PrivilegeGroupCollectionReadOnly)
1381-
}
1382-
"PrivilegeGroupCollectionReadWrite" => {
1383-
Some(Self::PrivilegeGroupCollectionReadWrite)
1384-
}
1337+
"PrivilegeGroupCollectionReadOnly" => Some(Self::PrivilegeGroupCollectionReadOnly),
1338+
"PrivilegeGroupCollectionReadWrite" => Some(Self::PrivilegeGroupCollectionReadWrite),
13851339
"PrivilegeGroupCollectionAdmin" => Some(Self::PrivilegeGroupCollectionAdmin),
13861340
_ => None,
13871341
}

0 commit comments

Comments
 (0)