Skip to content

Commit

Permalink
feat: upgrade to opendal 0.47 in object store
Browse files Browse the repository at this point in the history
  • Loading branch information
hzxa21 committed Jun 17, 2024
1 parent b6f8f46 commit 1eb05f5
Show file tree
Hide file tree
Showing 15 changed files with 326 additions and 110 deletions.
140 changes: 110 additions & 30 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 0 additions & 2 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -319,8 +319,6 @@ tokio-postgres = { git = "https://github.com/madsim-rs/rust-postgres.git", rev =
futures-timer = { git = "https://github.com/madsim-rs/futures-timer.git", rev = "05b33b4" }
# patch: unlimit 4MB message size for grpc client
etcd-client = { git = "https://github.com/risingwavelabs/etcd-client.git", rev = "4e84d40" }
# todo(wcy-fdu): remove this patch fork after opendal release a new version to apply azure workload identity change.
reqsign = { git = "https://github.com/wcy-fdu/reqsign.git", rev = "c7dd668" }
# patch to remove preserve_order from serde_json
deno_core = { git = "https://github.com/bakjos/deno_core", rev = "9b241c6" }
# patch to user reqwest 0.12.2
Expand Down
13 changes: 13 additions & 0 deletions src/common/src/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1086,8 +1086,17 @@ pub struct S3ObjectStoreDeveloperConfig {
)]
pub object_store_retryable_service_error_codes: Vec<String>,

// TODO: the following field will be deprecated after opendal is stablized
#[serde(default = "default::object_store_config::s3::developer::use_opendal")]
pub use_opendal: bool,

// TODO: the following field will be deprecated after opendal is stablized
#[serde(default = "default::object_store_config::s3::developer::upload_concurrency")]
pub upload_concurrency: usize,

// TODO: the following field will be deprecated after opendal is stablized
#[serde(default)]
pub writer_abort_on_err: bool,
}

#[derive(Clone, Debug, Serialize, Deserialize, DefaultFromSerde)]
Expand Down Expand Up @@ -2032,6 +2041,10 @@ pub mod default {
// 2. Change the default behavior to use opendal for s3 if RW_USE_OPENDAL_FOR_S3 is not set.
env_var_is_true_or(RW_USE_OPENDAL_FOR_S3, false)
}

pub fn upload_concurrency() -> usize {
8
}
}
}
}
Expand Down
Loading

0 comments on commit 1eb05f5

Please sign in to comment.