Skip to content

Commit

Permalink
fix(service/minitrace): update doc (#2621)
Browse files Browse the repository at this point in the history
  • Loading branch information
andylokandy committed Jul 12, 2023
1 parent 603ce61 commit c09efd1
Showing 1 changed file with 15 additions and 18 deletions.
33 changes: 15 additions & 18 deletions core/src/layers/minitrace.rs
Original file line number Diff line number Diff line change
Expand Up @@ -64,32 +64,29 @@ use crate::*;
/// fn main() -> Result<(), Box<dyn Error + Send + Sync + 'static>> {
/// let collector = {
/// let (span, collector) = minitrace::Span::root("op");
/// let _g = span.set_local_parent();
/// let runtime = tokio::runtime::Runtime::new()?;
///
/// runtime.block_on(async {
/// let _ = dotenvy::dotenv();
/// let op = Operator::from_env::<services::Memory>()
/// .expect("init operator must succeed")
/// .layer(MinitraceLayer)
/// .finish();
///
/// op.write("test", "0".repeat(16 * 1024 * 1024).into_bytes())
/// .await
/// .expect("must succeed");
/// op.stat("test").await.expect("must succeed");
/// op.read("test").await.expect("must succeed");
/// });
/// runtime.block_on(
/// async {
/// let _ = dotenvy::dotenv();
/// let op = Operator::from_env::<services::Memory>()
/// .expect("init operator must succeed")
/// .layer(MinitraceLayer)
/// .finish();
/// op.write("test", "0".repeat(16 * 1024 * 1024).into_bytes())
/// .await
/// .expect("must succeed");
/// op.stat("test").await.expect("must succeed");
/// op.read("test").await.expect("must succeed");
/// }
/// .in_span(Span::enter_with_parent("test", &span)),
/// );
/// collector
/// };
///
/// let spans = block_on(collector.collect());
///
/// let bytes =
/// minitrace_jaeger::encode("opendal".to_owned(), rand::random(), 0, 0, &spans).unwrap();
/// minitrace_jaeger::report_blocking("127.0.0.1:6831".parse().unwrap(), &bytes)
/// .expect("report error");
///
/// Ok(())
/// }
/// ```
Expand Down

0 comments on commit c09efd1

Please sign in to comment.