fmt

Author: G8XSU

src/io/vss_store.rs

@@ -28,7 +28,9 @@ impl VssStore {
 		Self { client, store_id, runtime }
 	}
 
-	fn build_key(&self, primary_namespace: &str, secondary_namespace: &str, key: &str) -> io::Result<String> {
+	fn build_key(
+		&self, primary_namespace: &str, secondary_namespace: &str, key: &str,
+	) -> io::Result<String> {
 		if primary_namespace.is_empty() {
 			Ok(key.to_string())
 		} else {
@@ -45,7 +47,9 @@ impl VssStore {
 		}
 	}
 
-	async fn list_all_keys(&self, primary_namespace: &str, secondary_namespace: &str) -> io::Result<Vec<String>> {
+	async fn list_all_keys(
+		&self, primary_namespace: &str, secondary_namespace: &str,
+	) -> io::Result<Vec<String>> {
 		let mut page_token = None;
 		let mut keys = vec![];
 		let key_prefix = format!("{}#{}", primary_namespace, secondary_namespace);
@@ -58,7 +62,10 @@ impl VssStore {
 			};
 
 			let response = self.client.list_key_versions(&request).await.map_err(|e| {
-				let msg = format!("Failed to list keys in {}/{}: {}", primary_namespace, secondary_namespace, e);
+				let msg = format!(
+					"Failed to list keys in {}/{}: {}",
+					primary_namespace, secondary_namespace, e
+				);
 				Error::new(ErrorKind::Other, msg)
 			})?;
 
@@ -72,7 +79,9 @@ impl VssStore {
 }
 
 impl KVStore for VssStore {
-	fn read(&self, primary_namespace: &str, secondary_namespace: &str, key: &str) -> io::Result<Vec<u8>> {
+	fn read(
+		&self, primary_namespace: &str, secondary_namespace: &str, key: &str,
+	) -> io::Result<Vec<u8>> {
 		check_namespace_key_validity(primary_namespace, secondary_namespace, Some(key), "read")?;
 		let request = GetObjectRequest {
 			store_id: self.store_id.to_string(),
@@ -100,7 +109,9 @@ impl KVStore for VssStore {
 		Ok(resp.value.unwrap().value)
 	}
 
-	fn write(&self, primary_namespace: &str, secondary_namespace: &str, key: &str, buf: &[u8]) -> io::Result<()> {
+	fn write(
+		&self, primary_namespace: &str, secondary_namespace: &str, key: &str, buf: &[u8],
+	) -> io::Result<()> {
 		check_namespace_key_validity(primary_namespace, secondary_namespace, Some(key), "write")?;
 		let request = PutObjectRequest {
 			store_id: self.store_id.to_string(),
@@ -140,8 +151,10 @@ impl KVStore for VssStore {
 
 		tokio::task::block_in_place(|| self.runtime.block_on(self.client.delete_object(&request)))
 			.map_err(|e| {
-				let msg =
-					format!("Failed to delete key {}/{}/{}: {}", primary_namespace, secondary_namespace, key, e);
+				let msg = format!(
+					"Failed to delete key {}/{}/{}: {}",
+					primary_namespace, secondary_namespace, key, e
+				);
 				Error::new(ErrorKind::Other, msg)
 			})?;
 		Ok(())