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

feat(obs): expose key S3 usecase spans at info (#3013)

Browse Source
This commit is contained in:
houseme
2026-05-19 19:00:51 +08:00
committed by GitHub
parent 25c6bdf490
commit d6fc70eb12
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rustfs/src/app/bucket_usecase.rs
+1 -1
View File
@@ -1908,7 +1908,7 @@ impl DefaultBucketUsecase {
Ok(S3Response::new(PutBucketVersioningOutput {})) Ok(S3Response::new(PutBucketVersioningOutput {}))
} }
#[instrument(level = "debug", skip(self, req))] #[instrument(level = "info", skip(self, req))]
pub async fn execute_list_objects_v2(&self, req: S3Request<ListObjectsV2Input>) -> S3Result<S3Response<ListObjectsV2Output>> { pub async fn execute_list_objects_v2(&self, req: S3Request<ListObjectsV2Input>) -> S3Result<S3Response<ListObjectsV2Output>> {
// warn!("list_objects_v2 req {:?}", &req.input); // warn!("list_objects_v2 req {:?}", &req.input);
let ListObjectsV2Input { let ListObjectsV2Input {
rustfs/src/app/object_usecase.rs
+3 -3
View File
@@ -1631,7 +1631,7 @@ impl DefaultObjectUsecase {
} }
} }
#[instrument(level = "debug", skip(self, _fs, req))] #[instrument(level = "info", skip(self, _fs, req))]
pub async fn execute_put_object(&self, _fs: &FS, req: S3Request<PutObjectInput>) -> S3Result<S3Response<PutObjectOutput>> { pub async fn execute_put_object(&self, _fs: &FS, req: S3Request<PutObjectInput>) -> S3Result<S3Response<PutObjectOutput>> {
let start_time = std::time::Instant::now(); let start_time = std::time::Instant::now();
let mut req = req; let mut req = req;
@@ -2182,7 +2182,7 @@ impl DefaultObjectUsecase {
} }
#[instrument( #[instrument(
level = "debug", level = "info",
skip(self, req), skip(self, req),
fields(start_time=?time::OffsetDateTime::now_utc()) fields(start_time=?time::OffsetDateTime::now_utc())
)] )]
@@ -3175,7 +3175,7 @@ impl DefaultObjectUsecase {
result result
} }
#[instrument(level = "debug", skip(self, req))] #[instrument(level = "info", skip(self, req))]
pub async fn execute_delete_object(&self, mut req: S3Request<DeleteObjectInput>) -> S3Result<S3Response<DeleteObjectOutput>> { pub async fn execute_delete_object(&self, mut req: S3Request<DeleteObjectInput>) -> S3Result<S3Response<DeleteObjectOutput>> {
if let Some(context) = &self.context { if let Some(context) = &self.context {
let _ = context.object_store(); let _ = context.object_store();