chore: fix typo

src/object/metadata.rs

@@ -399,7 +399,7 @@ flags! {
     ///
     /// At user side, we will allow user to query the object metadata. If
     /// the meta has been stored, we will return directly. If no, we will
-    /// call `stat` internally to fecth the metadata.
+    /// call `stat` internally to fetch the metadata.
     pub enum ObjectMetakey: u64 {
         /// The special object metadata key that used to mark this object
         /// already contains all metadata.

src/object/object.rs

@@ -301,7 +301,7 @@ impl Object {
     ///
     /// # Notes
     ///
-    /// - The returning contnet's length may be smaller than the range specified.
+    /// - The returning content's length may be smaller than the range specified.
     ///
     /// # Examples
     ///
@@ -445,7 +445,7 @@ impl Object {
     ///
     /// # Notes
     ///
-    /// - The returning contnet's length may be smaller than the range specified.
+    /// - The returning content's length may be smaller than the range specified.
     ///
     /// # Examples
     ///

src/object/writer.rs

@@ -153,7 +153,7 @@ impl AsyncWrite for ObjectWriter {
                     self.state = State::Close(Box::pin(fut));
                 }
                 State::Write(_) => {
-                    unreachable!("invlia state of writer: poll_close with State::Write")
+                    unreachable!("invalid state of writer: poll_close with State::Write")
                 }
                 State::Close(fut) => match ready!(fut.poll_unpin(cx)) {
                     Ok(w) => {

src/raw/accessor.rs

@@ -101,7 +101,7 @@ pub trait Accessor: Send + Sync + Debug + Unpin + 'static {
     /// # Behavior
     ///
     /// - Input path MUST be file path, DON'T NEED to check object mode.
-    /// - The returning contnet length may be smaller than the range specified.
+    /// - The returning content length may be smaller than the range specified.
     async fn read(&self, path: &str, args: OpRead) -> Result<(RpRead, Self::Reader)> {
         let (_, _) = (path, args);
 

src/raw/http_util/bytes_content_range.rs

@@ -44,7 +44,7 @@ use crate::Result;
 ///
 /// BytesContentRange implements `len()` but not `is_empty()` because it's useless.
 /// - When BytesContentRange's range is known, it must be non-empty.
-/// - When BytesContentRange's range is no known, we don't know whethre it's empty.
+/// - When BytesContentRange's range is no known, we don't know whether it's empty.
 #[allow(clippy::len_without_is_empty)]
 #[derive(Debug, Default, Clone, Copy, Eq, PartialEq, serde::Serialize, serde::Deserialize)]
 pub struct BytesContentRange(

src/raw/http_util/dns.rs

@@ -218,7 +218,7 @@ impl DnsCache {
         // entire cache to make more space.
         //
         // As described in DnsCache's doc, this limit should never be reached.
-        // We expect there only few entries holded in cache.
+        // We expect there only few entries held in cache.
         if guard.len() >= self.limits {
             guard.clear()
         }

src/raw/oio/into_reader/by_range.rs

@@ -192,7 +192,7 @@ impl<A: Accessor> oio::Read for RangeReader<A> {
                 // TODO: make this value configurable
                 if seek_pos > self.cur && seek_pos - self.cur < 1024 * 1024 {
                     // 212992 is the default read mem buffer of archlinux.
-                    // Ideally we should make this congiurable.
+                    // Ideally we should make this configurable.
                     //
                     // TODO: make this value configurable
                     let consume = cmp::min((seek_pos - self.cur) as usize, 212992);

src/raw/oio/into_streamable.rs

@@ -121,7 +121,7 @@ mod tests {
     }
 
     #[test]
-    fn test_into_stream_blocing() {
+    fn test_into_stream_blocking() {
         use oio::BlockingRead;
 
         let mut rng = ThreadRng::default();

src/raw/oio/read.rs

@@ -130,7 +130,7 @@ impl Read for () {
     }
 }
 
-/// `Box<dyn Read>` won't implement `Read` automanticly. To make Reader
+/// `Box<dyn Read>` won't implement `Read` automatically. To make Reader
 /// work as expected, we must add this impl.
 impl<T: Read + ?Sized> Read for Box<T> {
     fn poll_read(&mut self, cx: &mut Context<'_>, buf: &mut [u8]) -> Poll<Result<usize>> {
@@ -327,7 +327,7 @@ impl BlockingRead for () {
     }
 }
 
-/// `Box<dyn BlockingRead>` won't implement `BlockingRead` automanticly.
+/// `Box<dyn BlockingRead>` won't implement `BlockingRead` automatically.
 /// To make BlockingReader work as expected, we must add this impl.
 impl<T: BlockingRead + ?Sized> BlockingRead for Box<T> {
     fn read(&mut self, buf: &mut [u8]) -> Result<usize> {

src/raw/oio/to_hierarchy_pager.rs

@@ -39,7 +39,7 @@ pub fn to_hierarchy_pager<P>(pager: P, path: &str) -> ToHierarchyPager<P> {
 ///
 /// # Notes
 ///
-/// ToHierarchyPager filter entries after fecth entries. So it's possible
+/// ToHierarchyPager filter entries after fetch entries. So it's possible
 /// to return an empty vec. It doesn't mean the all pages have been
 /// returned.
 ///
@@ -58,7 +58,7 @@ impl<P> ToHierarchyPager<P> {
             .filter_map(|mut e| {
                 // If path is not started with prefix, drop it.
                 //
-                // Idealy, it should never happen. But we just tolerate
+                // Ideally, it should never happen. But we just tolerate
                 // this state.
                 if !e.path().starts_with(&self.path) {
                     return None;

src/raw/oio/write.rs

@@ -113,7 +113,7 @@ impl Write for () {
     }
 }
 
-/// `Box<dyn Write>` won't implement `Write` automanticly. To make Writer
+/// `Box<dyn Write>` won't implement `Write` automatically. To make Writer
 /// work as expected, we must add this impl.
 #[async_trait]
 impl<T: Write + ?Sized> Write for Box<T> {
@@ -169,7 +169,7 @@ impl BlockingWrite for () {
     }
 }
 
-/// `Box<dyn BlockingWrite>` won't implement `BlockingWrite` automanticly.
+/// `Box<dyn BlockingWrite>` won't implement `BlockingWrite` automatically.
 /// To make BlockingWriter work as expected, we must add this impl.
 impl<T: BlockingWrite + ?Sized> BlockingWrite for Box<T> {
     fn write(&mut self, bs: Bytes) -> Result<()> {

src/raw/rps.rs

@@ -149,7 +149,7 @@ impl RpBatch {
     }
 }
 
-/// Batch results of `bacth` operations.
+/// Batch results of `batch` operations.
 pub enum BatchedResults {
     /// results of delete batch operation
     Delete(Vec<(String, Result<RpDelete>)>),

src/services/fs/backend.rs

@@ -117,7 +117,7 @@ impl FsBuilder {
     /// behavior is consistent. By enable path check, we can make sure
     /// fs will behave the same as other services.
     ///
-    /// Enabling this feature will lead to etra metadata call in all
+    /// Enabling this feature will lead to extra metadata call in all
     /// operations.
     pub fn enable_path_check(&mut self) -> &mut Self {
         self.enable_path_check = true;

src/services/gcs/backend.rs

@@ -152,7 +152,7 @@ impl GcsBuilder {
     /// Set the GCS service account.
     ///
     /// service account will be used for fetch token from vm metadata.
-    /// If not set, we will try to fecth with `default` service account.
+    /// If not set, we will try to fetch with `default` service account.
     pub fn service_account(&mut self, service_account: &str) -> &mut Self {
         if !service_account.is_empty() {
             self.service_account = Some(service_account.to_string())
@@ -195,7 +195,7 @@ impl GcsBuilder {
         self
     }
 
-    /// Specify the signer directly instead of builling by OpenDAL.
+    /// Specify the signer directly instead of building by OpenDAL.
     ///
     /// If signer is specified, the following settings will not be used
     /// any more:
@@ -648,7 +648,7 @@ struct GetObjectJsonResponse {
     md5_hash: String,
     /// Content type of this object.
     ///
-    /// For examlpe: `"contentType": "image/png",`
+    /// For example: `"contentType": "image/png",`
     content_type: String,
 }
 

src/services/moka/backend.rs

@@ -152,7 +152,7 @@ impl Builder for MokaBuilder {
         let mut builder: CacheBuilder<String, Vec<u8>, _> =
             SegmentedCache::builder(self.num_segments.unwrap_or(1))
                 .thread_pool_enabled(self.thread_pool_enabled.unwrap_or(false));
-        // Use entries's bytes as capacity weigher.
+        // Use entries' bytes as capacity weigher.
         builder = builder.weigher(|k, v| (k.len() + v.len()) as u32);
         if let Some(v) = &self.name {
             builder = builder.name(v);