chore: Remove unnecessary expose of methods for ObjStoreClient

Signed-off-by: Piyush Singariya <piyushsingariya@gmail.com>

server/src/storage/s3.rs

@@ -237,7 +237,7 @@ impl<T: ObjectStore> ObjStoreClient <T> {
         }
     }
 
-    pub async fn _get_object(&self, path: &RelativePath) -> Result<Bytes, ObjectStorageError> {
+    async fn _get_object(&self, path: &RelativePath) -> Result<Bytes, ObjectStorageError> {
         let instant = Instant::now();
 
         let resp = self.client.get(&to_object_store_path(path)).await;
@@ -261,7 +261,7 @@ impl<T: ObjectStore> ObjStoreClient <T> {
         }
     }
 
-    pub async fn _put_object(
+    async fn _put_object(
         &self,
         path: &RelativePath,
         resource: PutPayload,
@@ -286,7 +286,7 @@ impl<T: ObjectStore> ObjStoreClient <T> {
         resp.map(|_| ()).map_err(|err| err.into())
     }
 
-    pub async fn _delete_prefix(&self, key: &str) -> Result<(), ObjectStorageError> {
+    async fn _delete_prefix(&self, key: &str) -> Result<(), ObjectStorageError> {
         let object_stream = self.client.list(Some(&(key.into())));
 
         object_stream
@@ -307,7 +307,7 @@ impl<T: ObjectStore> ObjStoreClient <T> {
         Ok(())
     }
 
-    pub async fn _list_streams(&self) -> Result<Vec<LogStream>, ObjectStorageError> {
+    async fn _list_streams(&self) -> Result<Vec<LogStream>, ObjectStorageError> {
         let resp = self.client.list_with_delimiter(None).await?;
 
         let common_prefixes = resp.common_prefixes; // get all dirs
@@ -337,7 +337,7 @@ impl<T: ObjectStore> ObjStoreClient <T> {
         Ok(dirs.into_iter().map(|name| LogStream { name }).collect())
     }
 
-    pub async fn _list_dates(&self, stream: &str) -> Result<Vec<String>, ObjectStorageError> {
+    async fn _list_dates(&self, stream: &str) -> Result<Vec<String>, ObjectStorageError> {
         let resp = self
             .client
             .list_with_delimiter(Some(&(stream.into())))
@@ -355,7 +355,7 @@ impl<T: ObjectStore> ObjStoreClient <T> {
         Ok(dates)
     }
 
-    pub async fn _list_manifest_files(
+    async fn _list_manifest_files(
         &self,
         stream: &str,
     ) -> Result<BTreeMap<String, Vec<String>>, ObjectStorageError> {
@@ -385,7 +385,7 @@ impl<T: ObjectStore> ObjStoreClient <T> {
         }
         Ok(result_file_list)
     }
-    pub async fn _upload_file(&self, key: &str, path: &StdPath) -> Result<(), ObjectStorageError> {
+    async fn _upload_file(&self, key: &str, path: &StdPath) -> Result<(), ObjectStorageError> {
         let instant = Instant::now();
 
         // // TODO: Uncomment this when multipart is fixed