This is an automated email from the ASF dual-hosted git repository.
xuanwo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git
The following commit(s) were added to refs/heads/main by this push:
new df79fb635 chore(service/minitrace): automatically generate span name
(#2618)
df79fb635 is described below
commit df79fb63546f3d64169b2c69c45ab313136f85e2
Author: Andy Lok <[email protected]>
AuthorDate: Wed Jul 12 14:49:06 2023 +0800
chore(service/minitrace): automatically generate span name (#2618)
---
core/Cargo.toml | 2 +-
core/src/layers/minitrace.rs | 22 +++++++++++-----------
2 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/core/Cargo.toml b/core/Cargo.toml
index d4287eca2..f30dd780b 100644
--- a/core/Cargo.toml
+++ b/core/Cargo.toml
@@ -201,7 +201,7 @@ madsim = { version = "0.2.21", optional = true }
md-5 = "0.10"
metrics = { version = "0.20", optional = true }
mini-moka = { version = "0.10", optional = true }
-minitrace = { version = "0.4.0", optional = true }
+minitrace = { version = "0.4.1", optional = true }
moka = { version = "0.10", optional = true, features = ["future"] }
once_cell = "1"
openssh = { version = "0.9.9", optional = true }
diff --git a/core/src/layers/minitrace.rs b/core/src/layers/minitrace.rs
index c60846731..c7d7165e6 100644
--- a/core/src/layers/minitrace.rs
+++ b/core/src/layers/minitrace.rs
@@ -172,22 +172,22 @@ impl<A: Accessor> LayeredAccessor for
MinitraceAccessor<A> {
self.inner.append(path, args).await
}
- #[trace("copy", enter_on_poll = true)]
+ #[trace(enter_on_poll = true)]
async fn copy(&self, from: &str, to: &str, args: OpCopy) -> Result<RpCopy>
{
self.inner().copy(from, to, args).await
}
- #[trace("rename", enter_on_poll = true)]
+ #[trace(enter_on_poll = true)]
async fn rename(&self, from: &str, to: &str, args: OpRename) ->
Result<RpRename> {
self.inner().rename(from, to, args).await
}
- #[trace("stat", enter_on_poll = true)]
+ #[trace(enter_on_poll = true)]
async fn stat(&self, path: &str, args: OpStat) -> Result<RpStat> {
self.inner.stat(path, args).await
}
- #[trace("delete", enter_on_poll = true)]
+ #[trace(enter_on_poll = true)]
async fn delete(&self, path: &str, args: OpDelete) -> Result<RpDelete> {
self.inner.delete(path, args).await
}
@@ -200,17 +200,17 @@ impl<A: Accessor> LayeredAccessor for
MinitraceAccessor<A> {
.await
}
- #[trace("presign", enter_on_poll = true)]
+ #[trace(enter_on_poll = true)]
async fn presign(&self, path: &str, args: OpPresign) -> Result<RpPresign> {
self.inner.presign(path, args).await
}
- #[trace("batch", enter_on_poll = true)]
+ #[trace(enter_on_poll = true)]
async fn batch(&self, args: OpBatch) -> Result<RpBatch> {
self.inner.batch(args).await
}
- #[trace("blocking_create")]
+ #[trace]
fn blocking_create_dir(&self, path: &str, args: OpCreateDir) ->
Result<RpCreateDir> {
self.inner.blocking_create_dir(path, args)
}
@@ -235,22 +235,22 @@ impl<A: Accessor> LayeredAccessor for
MinitraceAccessor<A> {
})
}
- #[trace("blocking_copy")]
+ #[trace]
fn blocking_copy(&self, from: &str, to: &str, args: OpCopy) ->
Result<RpCopy> {
self.inner().blocking_copy(from, to, args)
}
- #[trace("blocking_rename")]
+ #[trace]
fn blocking_rename(&self, from: &str, to: &str, args: OpRename) ->
Result<RpRename> {
self.inner().blocking_rename(from, to, args)
}
- #[trace("blocking_stat")]
+ #[trace]
fn blocking_stat(&self, path: &str, args: OpStat) -> Result<RpStat> {
self.inner.blocking_stat(path, args)
}
- #[trace("blocking_delete")]
+ #[trace]
fn blocking_delete(&self, path: &str, args: OpDelete) -> Result<RpDelete> {
self.inner.blocking_delete(path, args)
}