gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-07-26 08:18:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix/event (#514)

Browse Source 
* improve code for notify

* fix

* cargo fmt

* improve code and create `DEFAULT_DELIMITER`

* fix

* fix

* improve code for notify

* fmt

* Update crates/notify/src/registry.rs

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update crates/notify/src/factory.rs

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* fix cllipy

* fix

* fix

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
This commit is contained in:
houseme
2025-06-27 09:41:29 +08:00
committed by GitHub
parent 26f84a9696
commit 2698d3aa10
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/utils/Cargo.toml
+1 -1
View File
@@ -66,7 +66,7 @@ path = []
notify = ["dep:hyper", "dep:s3s"] # file system notification features
compress = ["dep:flate2", "dep:brotli", "dep:snap", "dep:lz4", "dep:zstd"]
string = ["dep:regex", "dep:lazy_static", "dep:rand"]
crypto = ["dep:base64-simd", "dep:hex-simd", "dep:hmac", "dep:hyper"]
crypto = ["dep:base64-simd", "dep:hex-simd", "dep:hmac", "dep:hyper", "dep:sha1"]
hash = ["dep:highway", "dep:md-5", "dep:sha2", "dep:blake3", "dep:serde", "dep:siphasher"]
os = ["dep:nix", "dep:tempfile", "winapi"] # operating system utilities
integration = [] # integration test features
rustfs/src/storage/ecfs.rs
+4 -4
View File
@@ -221,7 +221,7 @@ impl FS {
.await
.map_err(ApiError::from)?;
// let e_tag = obj_info.etag;
let e_tag = _obj_info.clone().etag;
// // store.put_object(bucket, object, data, opts);
@@ -235,9 +235,9 @@ impl FS {
bucket_name: bucket.clone(),
object: _obj_info.clone(), // clone() 或传递所需字段
req_params: rustfs_utils::extract_req_params_header(&req.headers), // 假设有一个辅助函数来提取请求参数
resp_elements: rustfs_utils::extract_resp_elements(&output), // 假设有一个辅助函数来提取响应元素
host: rustfs_utils::get_request_host(&req.headers), // 假设的辅助函数
user_agent: rustfs_utils::get_request_user_agent(&req.headers), // 假设的辅助函数
resp_elements: rustfs_utils::extract_resp_elements(&S3Response::new(output.clone())), // 假设有一个辅助函数来提取响应元素
host: rustfs_utils::get_request_host(&req.headers), // 假设的辅助函数
user_agent: rustfs_utils::get_request_user_agent(&req.headers), // 假设的辅助函数
};
// 异步调用，不会阻塞当前请求的响应