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

fix(metrics): preserve object operation labels

Browse Source
This commit is contained in:
马登山
2026-08-13 17:56:36 +08:00
parent f0fb77f35a
commit cdd30c0126
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rustfs/src/app/object_usecase.rs
+6 -3
View File
@@ -6551,8 +6551,11 @@ impl DefaultObjectUsecase {
Box::pin(self.execute_get_object_inner(req))
}
#[instrument(name = "DefaultObjectUsecase::execute_get_object", level = "trace", skip(self, req))]
#[hotpath::measure(label = "DefaultObjectUsecase::execute_get_object", impl_type = "DefaultObjectUsecase")]
#[instrument(name = "execute_get_object", level = "trace", skip(self, req))]
#[hotpath::measure(
label = "rustfs::app::object_usecase::DefaultObjectUsecase::execute_get_object",
impl_type = "DefaultObjectUsecase"
)]
async fn execute_get_object_inner(&self, req: S3Request<GetObjectInput>) -> S3Result<S3Response<GetObjectOutput>> {
if let Some(context) = &self.context {
let _ = context.object_store();
@@ -7014,7 +7017,7 @@ impl DefaultObjectUsecase {
Box::pin(self.execute_copy_object_inner(req))
}
#[instrument(name = "DefaultObjectUsecase::execute_copy_object", level = "debug", skip(self, req))]
#[instrument(name = "execute_copy_object", level = "debug", skip(self, req))]
async fn execute_copy_object_inner(&self, req: S3Request<CopyObjectInput>) -> S3Result<S3Response<CopyObjectOutput>> {
if let Some(context) = &self.context {
let _ = context.object_store();