Skip to content

Commit d82a365

Browse files
author
Yinwei Li
committed
format the code
Signed-off-by: Yinwei Li <yinwei.li@zilliz.com>
1 parent f342185 commit d82a365

File tree

17 files changed

+701
-1121
lines changed

17 files changed

+701
-1121
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/data.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ impl From<FieldColumn> for schema::FieldData {
163163
schema::FieldData {
164164
field_name: this.name.to_string(),
165165
field_id: 0,
166-
valid_data:vec![],
166+
valid_data: vec![],
167167
r#type: this.dtype as _,
168168
field: Some(match this.value {
169169
ValueVec::None => Field::Scalars(ScalarField { data: None }),

‎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/mutate.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ impl Client {
9999
num_rows: row_num as u32,
100100
fields_data: fields_data.into_iter().map(|f| f.into()).collect(),
101101
hash_keys: Vec::new(),
102-
schema_timestamp:0,
102+
schema_timestamp: 0,
103103
})
104104
.await?
105105
.into_inner();
@@ -129,8 +129,8 @@ impl Client {
129129
expr: expr,
130130
partition_name: options.partition_name.clone(),
131131
hash_keys: Vec::new(),
132-
consistency_level:crate::proto::common::ConsistencyLevel::Strong.into(),
133-
expr_template_values:std::collections::HashMap::new(),
132+
consistency_level: crate::proto::common::ConsistencyLevel::Strong.into(),
133+
expr_template_values: std::collections::HashMap::new(),
134134
})
135135
.await?
136136
.into_inner();
@@ -212,7 +212,7 @@ impl Client {
212212
num_rows: row_num as u32,
213213
fields_data: fields_data.into_iter().map(|f| f.into()).collect(),
214214
hash_keys: Vec::new(),
215-
schema_timestamp:0,
215+
schema_timestamp: 0,
216216
})
217217
.await?
218218
.into_inner();

‎src/proto/milvus.proto.common.rs‎

Lines changed: 27 additions & 73 deletions
Original file line numberDiff line numberDiff line change
@@ -13,10 +13,8 @@ pub struct Status {
1313
#[prost(string, tag = "5")]
1414
pub detail: ::prost::alloc::string::String,
1515
#[prost(map = "string, string", tag = "6")]
16-
pub extra_info: ::std::collections::HashMap<
17-
::prost::alloc::string::String,
18-
::prost::alloc::string::String,
19-
>,
16+
pub extra_info:
17+
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
2018
}
2119
#[allow(clippy::derive_partial_eq_without_eq)]
2220
#[derive(Clone, PartialEq, ::prost::Message)]
@@ -81,10 +79,8 @@ pub struct MsgBase {
8179
#[prost(int64, tag = "5")]
8280
pub target_id: i64,
8381
#[prost(map = "string, string", tag = "6")]
84-
pub properties: ::std::collections::HashMap<
85-
::prost::alloc::string::String,
86-
::prost::alloc::string::String,
87-
>,
82+
pub properties:
83+
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
8884
#[prost(message, optional, tag = "7")]
8985
pub replicate_info: ::core::option::Option<ReplicateInfo>,
9086
}
@@ -151,10 +147,8 @@ pub struct ClientInfo {
151147
pub host: ::prost::alloc::string::String,
152148
/// reserved for newly-added feature if necessary.
153149
#[prost(map = "string, string", tag = "6")]
154-
pub reserved: ::std::collections::HashMap<
155-
::prost::alloc::string::String,
156-
::prost::alloc::string::String,
157-
>,
150+
pub reserved:
151+
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
158152
}
159153
#[allow(clippy::derive_partial_eq_without_eq)]
160154
#[derive(Clone, PartialEq, ::prost::Message)]
@@ -171,10 +165,8 @@ pub struct ServerInfo {
171165
pub deploy_mode: ::prost::alloc::string::String,
172166
/// reserved for newly-added feature if necessary.
173167
#[prost(map = "string, string", tag = "6")]
174-
pub reserved: ::std::collections::HashMap<
175-
::prost::alloc::string::String,
176-
::prost::alloc::string::String,
177-
>,
168+
pub reserved:
169+
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
178170
}
179171
/// NodeInfo is used to describe the node information.
180172
#[allow(clippy::derive_partial_eq_without_eq)]
@@ -1234,13 +1226,9 @@ impl ObjectPrivilege {
12341226
ObjectPrivilege::PrivilegeManageOwnership => "PrivilegeManageOwnership",
12351227
ObjectPrivilege::PrivilegeSelectUser => "PrivilegeSelectUser",
12361228
ObjectPrivilege::PrivilegeUpsert => "PrivilegeUpsert",
1237-
ObjectPrivilege::PrivilegeCreateResourceGroup => {
1238-
"PrivilegeCreateResourceGroup"
1239-
}
1229+
ObjectPrivilege::PrivilegeCreateResourceGroup => "PrivilegeCreateResourceGroup",
12401230
ObjectPrivilege::PrivilegeDropResourceGroup => "PrivilegeDropResourceGroup",
1241-
ObjectPrivilege::PrivilegeDescribeResourceGroup => {
1242-
"PrivilegeDescribeResourceGroup"
1243-
}
1231+
ObjectPrivilege::PrivilegeDescribeResourceGroup => "PrivilegeDescribeResourceGroup",
12441232
ObjectPrivilege::PrivilegeListResourceGroups => "PrivilegeListResourceGroups",
12451233
ObjectPrivilege::PrivilegeTransferNode => "PrivilegeTransferNode",
12461234
ObjectPrivilege::PrivilegeTransferReplica => "PrivilegeTransferReplica",
@@ -1260,49 +1248,29 @@ impl ObjectPrivilege {
12601248
ObjectPrivilege::PrivilegeDropAlias => "PrivilegeDropAlias",
12611249
ObjectPrivilege::PrivilegeDescribeAlias => "PrivilegeDescribeAlias",
12621250
ObjectPrivilege::PrivilegeListAliases => "PrivilegeListAliases",
1263-
ObjectPrivilege::PrivilegeUpdateResourceGroups => {
1264-
"PrivilegeUpdateResourceGroups"
1265-
}
1251+
ObjectPrivilege::PrivilegeUpdateResourceGroups => "PrivilegeUpdateResourceGroups",
12661252
ObjectPrivilege::PrivilegeAlterDatabase => "PrivilegeAlterDatabase",
12671253
ObjectPrivilege::PrivilegeDescribeDatabase => "PrivilegeDescribeDatabase",
12681254
ObjectPrivilege::PrivilegeBackupRbac => "PrivilegeBackupRBAC",
12691255
ObjectPrivilege::PrivilegeRestoreRbac => "PrivilegeRestoreRBAC",
12701256
ObjectPrivilege::PrivilegeGroupReadOnly => "PrivilegeGroupReadOnly",
12711257
ObjectPrivilege::PrivilegeGroupReadWrite => "PrivilegeGroupReadWrite",
12721258
ObjectPrivilege::PrivilegeGroupAdmin => "PrivilegeGroupAdmin",
1273-
ObjectPrivilege::PrivilegeCreatePrivilegeGroup => {
1274-
"PrivilegeCreatePrivilegeGroup"
1275-
}
1259+
ObjectPrivilege::PrivilegeCreatePrivilegeGroup => "PrivilegeCreatePrivilegeGroup",
12761260
ObjectPrivilege::PrivilegeDropPrivilegeGroup => "PrivilegeDropPrivilegeGroup",
1277-
ObjectPrivilege::PrivilegeListPrivilegeGroups => {
1278-
"PrivilegeListPrivilegeGroups"
1279-
}
1280-
ObjectPrivilege::PrivilegeOperatePrivilegeGroup => {
1281-
"PrivilegeOperatePrivilegeGroup"
1282-
}
1283-
ObjectPrivilege::PrivilegeGroupClusterReadOnly => {
1284-
"PrivilegeGroupClusterReadOnly"
1285-
}
1286-
ObjectPrivilege::PrivilegeGroupClusterReadWrite => {
1287-
"PrivilegeGroupClusterReadWrite"
1288-
}
1261+
ObjectPrivilege::PrivilegeListPrivilegeGroups => "PrivilegeListPrivilegeGroups",
1262+
ObjectPrivilege::PrivilegeOperatePrivilegeGroup => "PrivilegeOperatePrivilegeGroup",
1263+
ObjectPrivilege::PrivilegeGroupClusterReadOnly => "PrivilegeGroupClusterReadOnly",
1264+
ObjectPrivilege::PrivilegeGroupClusterReadWrite => "PrivilegeGroupClusterReadWrite",
12891265
ObjectPrivilege::PrivilegeGroupClusterAdmin => "PrivilegeGroupClusterAdmin",
1290-
ObjectPrivilege::PrivilegeGroupDatabaseReadOnly => {
1291-
"PrivilegeGroupDatabaseReadOnly"
1292-
}
1293-
ObjectPrivilege::PrivilegeGroupDatabaseReadWrite => {
1294-
"PrivilegeGroupDatabaseReadWrite"
1295-
}
1266+
ObjectPrivilege::PrivilegeGroupDatabaseReadOnly => "PrivilegeGroupDatabaseReadOnly",
1267+
ObjectPrivilege::PrivilegeGroupDatabaseReadWrite => "PrivilegeGroupDatabaseReadWrite",
12961268
ObjectPrivilege::PrivilegeGroupDatabaseAdmin => "PrivilegeGroupDatabaseAdmin",
1297-
ObjectPrivilege::PrivilegeGroupCollectionReadOnly => {
1298-
"PrivilegeGroupCollectionReadOnly"
1299-
}
1269+
ObjectPrivilege::PrivilegeGroupCollectionReadOnly => "PrivilegeGroupCollectionReadOnly",
13001270
ObjectPrivilege::PrivilegeGroupCollectionReadWrite => {
13011271
"PrivilegeGroupCollectionReadWrite"
13021272
}
1303-
ObjectPrivilege::PrivilegeGroupCollectionAdmin => {
1304-
"PrivilegeGroupCollectionAdmin"
1305-
}
1273+
ObjectPrivilege::PrivilegeGroupCollectionAdmin => "PrivilegeGroupCollectionAdmin",
13061274
ObjectPrivilege::PrivilegeGetImportProgress => "PrivilegeGetImportProgress",
13071275
ObjectPrivilege::PrivilegeListImport => "PrivilegeListImport",
13081276
ObjectPrivilege::PrivilegeAddCollectionField => "PrivilegeAddCollectionField",
@@ -1339,9 +1307,7 @@ impl ObjectPrivilege {
13391307
"PrivilegeUpsert" => Some(Self::PrivilegeUpsert),
13401308
"PrivilegeCreateResourceGroup" => Some(Self::PrivilegeCreateResourceGroup),
13411309
"PrivilegeDropResourceGroup" => Some(Self::PrivilegeDropResourceGroup),
1342-
"PrivilegeDescribeResourceGroup" => {
1343-
Some(Self::PrivilegeDescribeResourceGroup)
1344-
}
1310+
"PrivilegeDescribeResourceGroup" => Some(Self::PrivilegeDescribeResourceGroup),
13451311
"PrivilegeListResourceGroups" => Some(Self::PrivilegeListResourceGroups),
13461312
"PrivilegeTransferNode" => Some(Self::PrivilegeTransferNode),
13471313
"PrivilegeTransferReplica" => Some(Self::PrivilegeTransferReplica),
@@ -1372,27 +1338,15 @@ impl ObjectPrivilege {
13721338
"PrivilegeCreatePrivilegeGroup" => Some(Self::PrivilegeCreatePrivilegeGroup),
13731339
"PrivilegeDropPrivilegeGroup" => Some(Self::PrivilegeDropPrivilegeGroup),
13741340
"PrivilegeListPrivilegeGroups" => Some(Self::PrivilegeListPrivilegeGroups),
1375-
"PrivilegeOperatePrivilegeGroup" => {
1376-
Some(Self::PrivilegeOperatePrivilegeGroup)
1377-
}
1341+
"PrivilegeOperatePrivilegeGroup" => Some(Self::PrivilegeOperatePrivilegeGroup),
13781342
"PrivilegeGroupClusterReadOnly" => Some(Self::PrivilegeGroupClusterReadOnly),
1379-
"PrivilegeGroupClusterReadWrite" => {
1380-
Some(Self::PrivilegeGroupClusterReadWrite)
1381-
}
1343+
"PrivilegeGroupClusterReadWrite" => Some(Self::PrivilegeGroupClusterReadWrite),
13821344
"PrivilegeGroupClusterAdmin" => Some(Self::PrivilegeGroupClusterAdmin),
1383-
"PrivilegeGroupDatabaseReadOnly" => {
1384-
Some(Self::PrivilegeGroupDatabaseReadOnly)
1385-
}
1386-
"PrivilegeGroupDatabaseReadWrite" => {
1387-
Some(Self::PrivilegeGroupDatabaseReadWrite)
1388-
}
1345+
"PrivilegeGroupDatabaseReadOnly" => Some(Self::PrivilegeGroupDatabaseReadOnly),
1346+
"PrivilegeGroupDatabaseReadWrite" => Some(Self::PrivilegeGroupDatabaseReadWrite),
13891347
"PrivilegeGroupDatabaseAdmin" => Some(Self::PrivilegeGroupDatabaseAdmin),
1390-
"PrivilegeGroupCollectionReadOnly" => {
1391-
Some(Self::PrivilegeGroupCollectionReadOnly)
1392-
}
1393-
"PrivilegeGroupCollectionReadWrite" => {
1394-
Some(Self::PrivilegeGroupCollectionReadWrite)
1395-
}
1348+
"PrivilegeGroupCollectionReadOnly" => Some(Self::PrivilegeGroupCollectionReadOnly),
1349+
"PrivilegeGroupCollectionReadWrite" => Some(Self::PrivilegeGroupCollectionReadWrite),
13961350
"PrivilegeGroupCollectionAdmin" => Some(Self::PrivilegeGroupCollectionAdmin),
13971351
"PrivilegeGetImportProgress" => Some(Self::PrivilegeGetImportProgress),
13981352
"PrivilegeListImport" => Some(Self::PrivilegeListImport),

0 commit comments

Comments
 (0)