degrade rand && object_store

Signed-off-by: junxiang Mu <1948535941@qq.com>

Cargo.lock

@@ -190,7 +190,7 @@ dependencies = [
  "futures",
  "futures-core",
  "http",
- "object_store 0.12.0",
+ "object_store",
  "s3s",
  "snafu",
  "tokio",
@@ -207,7 +207,7 @@ dependencies = [
  "base64-simd",
  "common",
  "hex-simd",
- "rand 0.9.0",
+ "rand 0.8.5",
  "rsa",
  "serde",
  "serde_json",
@@ -1653,7 +1653,7 @@ dependencies = [
  "chacha20poly1305",
  "jsonwebtoken",
  "pbkdf2",
- "rand 0.9.0",
+ "rand 0.8.5",
  "serde_json",
  "sha2 0.10.8",
  "test-case",
@@ -1843,7 +1843,7 @@ dependencies = [
  "futures",
  "itertools 0.14.0",
  "log",
- "object_store 0.11.2",
+ "object_store",
  "parking_lot 0.12.3",
  "parquet",
  "rand 0.8.5",
@@ -1895,7 +1895,7 @@ dependencies = [
  "datafusion-physical-plan",
  "futures",
  "log",
- "object_store 0.11.2",
+ "object_store",
  "tokio",
 ]
 
@@ -1914,7 +1914,7 @@ dependencies = [
  "indexmap 2.8.0",
  "libc",
  "log",
- "object_store 0.11.2",
+ "object_store",
  "parquet",
  "paste",
  "recursive",
@@ -1958,7 +1958,7 @@ dependencies = [
  "glob",
  "itertools 0.14.0",
  "log",
- "object_store 0.11.2",
+ "object_store",
  "rand 0.8.5",
  "tokio",
  "tokio-util",
@@ -1985,7 +1985,7 @@ dependencies = [
  "datafusion-expr",
  "futures",
  "log",
- "object_store 0.11.2",
+ "object_store",
  "parking_lot 0.12.3",
  "rand 0.8.5",
  "tempfile",
@@ -3021,7 +3021,7 @@ dependencies = [
  "pin-project-lite",
  "policy",
  "protos",
- "rand 0.9.0",
+ "rand 0.8.5",
  "reed-solomon-erasure",
  "regex",
  "reqwest",
@@ -4086,7 +4086,7 @@ dependencies = [
  "lazy_static",
  "madmin",
  "policy",
- "rand 0.9.0",
+ "rand 0.8.5",
  "regex",
  "serde",
  "serde_json",
@@ -4746,7 +4746,7 @@ dependencies = [
  "common",
  "lazy_static",
  "protos",
- "rand 0.9.0",
+ "rand 0.8.5",
  "serde",
  "serde_json",
  "tokio",
@@ -5504,28 +5504,6 @@ dependencies = [
  "walkdir",
 ]
 
-[[package]]
-name = "object_store"
-version = "0.12.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e9ce831b09395f933addbc56d894d889e4b226eba304d4e7adbab591e26daf1e"
-dependencies = [
- "async-trait",
- "bytes",
- "chrono",
- "futures",
- "http",
- "humantime",
- "itertools 0.14.0",
- "parking_lot 0.12.3",
- "percent-encoding",
- "thiserror 2.0.12",
- "tokio",
- "tracing",
- "url",
- "walkdir",
-]
-
 [[package]]
 name = "once_cell"
 version = "1.21.3"
@@ -5815,7 +5793,7 @@ dependencies = [
  "lz4_flex",
  "num",
  "num-bigint",
- "object_store 0.11.2",
+ "object_store",
  "paste",
  "seq-macro",
  "simdutf8",
@@ -6200,7 +6178,7 @@ dependencies = [
  "jsonwebtoken",
  "lazy_static",
  "madmin",
- "rand 0.9.0",
+ "rand 0.8.5",
  "regex",
  "serde",
  "serde_json",

Cargo.toml

@@ -82,7 +82,7 @@ prost-build = "0.13.4"
 prost-types = "0.13.4"
 protobuf = "3.7"
 protos = { path = "./common/protos" }
-rand = "0.9.0"
+rand = "0.8.5"
 rdkafka = { version = "0.37", features = ["tokio"] }
 reqwest = { version = "0.12.15", default-features = false, features = ["rustls-tls", "charset", "http2", "macos-system-configuration", "stream", "json", "blocking"] }
 rfd = { version = "0.15.2", default-features = false, features = ["xdg-portal", "tokio"] }

common/protos/src/generated/flatbuffers_generated/models.rs

@@ -1,10 +1,9 @@
 // automatically generated by the FlatBuffers compiler, do not modify
 
-
 // @generated
 
-use core::mem;
 use core::cmp::Ordering;
+use core::mem;
 
 extern crate flatbuffers;
 use self::flatbuffers::{EndianScalar, Follow};
@@ -12,8 +11,8 @@ use self::flatbuffers::{EndianScalar, Follow};
 #[allow(unused_imports, dead_code)]
 pub mod models {
 
-  use core::mem;
     use core::cmp::Ordering;
+    use core::mem;
 
     extern crate flatbuffers;
     use self::flatbuffers::{EndianScalar, Follow};
@@ -29,7 +28,9 @@ impl<'a> flatbuffers::Follow<'a> for PingBody<'a> {
         type Inner = PingBody<'a>;
         #[inline]
         unsafe fn follow(buf: &'a [u8], loc: usize) -> Self::Inner {
-    Self { _tab: flatbuffers::Table::new(buf, loc) }
+            Self {
+                _tab: flatbuffers::Table::new(buf, loc),
+            }
         }
     }
 
@@ -47,28 +48,30 @@ impl<'a> PingBody<'a> {
         #[allow(unused_mut)]
         pub fn create<'bldr: 'args, 'args: 'mut_bldr, 'mut_bldr, A: flatbuffers::Allocator + 'bldr>(
             _fbb: &'mut_bldr mut flatbuffers::FlatBufferBuilder<'bldr, A>,
-    args: &'args PingBodyArgs<'args>
+            args: &'args PingBodyArgs<'args>,
         ) -> flatbuffers::WIPOffset<PingBody<'bldr>> {
             let mut builder = PingBodyBuilder::new(_fbb);
-    if let Some(x) = args.payload { builder.add_payload(x); }
+            if let Some(x) = args.payload {
+                builder.add_payload(x);
+            }
             builder.finish()
         }
 
-
         #[inline]
         pub fn payload(&self) -> Option<flatbuffers::Vector<'a, u8>> {
             // Safety:
             // Created from valid Table for this object
             // which contains a valid value in this slot
-    unsafe { self._tab.get::<flatbuffers::ForwardsUOffset<flatbuffers::Vector<'a, u8>>>(PingBody::VT_PAYLOAD, None)}
+            unsafe {
+                self._tab
+                    .get::<flatbuffers::ForwardsUOffset<flatbuffers::Vector<'a, u8>>>(PingBody::VT_PAYLOAD, None)
+            }
         }
     }
 
     impl flatbuffers::Verifiable for PingBody<'_> {
         #[inline]
-  fn run_verifier(
+        fn run_verifier(v: &mut flatbuffers::Verifier, pos: usize) -> Result<(), flatbuffers::InvalidFlatbuffer> {
-    v: &mut flatbuffers::Verifier, pos: usize
-  ) -> Result<(), flatbuffers::InvalidFlatbuffer> {
             use self::flatbuffers::Verifiable;
             v.visit_table(pos)?
                 .visit_field::<flatbuffers::ForwardsUOffset<flatbuffers::Vector<'_, u8>>>("payload", Self::VT_PAYLOAD, false)?
@@ -82,9 +85,7 @@ pub struct PingBodyArgs<'a> {
     impl<'a> Default for PingBodyArgs<'a> {
         #[inline]
         fn default() -> Self {
-    PingBodyArgs {
+            PingBodyArgs { payload: None }
-      payload: None,
-    }
         }
     }
 
@@ -95,7 +96,8 @@ pub struct PingBodyBuilder<'a: 'b, 'b, A: flatbuffers::Allocator + 'a> {
     impl<'a: 'b, 'b, A: flatbuffers::Allocator + 'a> PingBodyBuilder<'a, 'b, A> {
         #[inline]
         pub fn add_payload(&mut self, payload: flatbuffers::WIPOffset<flatbuffers::Vector<'b, u8>>) {
-    self.fbb_.push_slot_always::<flatbuffers::WIPOffset<_>>(PingBody::VT_PAYLOAD, payload);
+            self.fbb_
+                .push_slot_always::<flatbuffers::WIPOffset<_>>(PingBody::VT_PAYLOAD, payload);
         }
         #[inline]
         pub fn new(_fbb: &'b mut flatbuffers::FlatBufferBuilder<'a, A>) -> PingBodyBuilder<'a, 'b, A> {
@@ -120,4 +122,3 @@ impl core::fmt::Debug for PingBody<'_> {
         }
     }
 } // pub mod models
-

ecstore/src/disk/local.rs

@@ -14,7 +14,7 @@ use crate::bucket::metadata_sys::{self};
 use crate::cache_value::cache::{Cache, Opts, UpdateFn};
 use crate::disk::error::{
     convert_access_error, is_err_os_not_exist, is_sys_err_handle_invalid, is_sys_err_invalid_arg, is_sys_err_is_dir,
-    is_sys_err_not_dir, map_err_not_exists, os_err_to_file_err, FileAccessDeniedWithContext
+    is_sys_err_not_dir, map_err_not_exists, os_err_to_file_err, FileAccessDeniedWithContext,
 };
 use crate::disk::os::{check_path_length, is_empty_dir};
 use crate::disk::STORAGE_FORMAT_FILE;

s3select/api/Cargo.toml

@@ -12,7 +12,7 @@ ecstore.workspace = true
 futures = { workspace = true }
 futures-core = "0.3.31"
 http.workspace = true
-object_store = "0.12.0"
+object_store = "0.11.2"
 s3s.workspace = true
 snafu = { workspace = true, features = ["backtrace"] }
 tokio.workspace = true