commit | 39232e5bd11ba2b4aee45484ea9d3d424e0aaaad | [log] [tgz] |
---|---|---|
author | tison <wander4096@gmail.com> | Sun Jan 23 00:43:40 2022 +0800 |
committer | GitHub <noreply@github.com> | Sun Jan 23 01:43:40 2022 +0900 |
tree | 578aa8fb00c5df3afdef9873858995526fdb44c7 | |
parent | f4743a98aba7f6a1f9f40d90eb45621466b7f5c8 [diff] |
harden e2e test by adding healthCheck (#10) * harden e2e test by adding healthCheck Signed-off-by: tison <wander4096@gmail.com> * retrigger Signed-off-by: tison <wander4096@gmail.com> * retrigger Signed-off-by: tison <wander4096@gmail.com> * retrigger Signed-off-by: tison <wander4096@gmail.com> * move probe to the e2e script Signed-off-by: tison <wander4096@gmail.com> * trigger ci Signed-off-by: tison <wander4096@gmail.com> * trigger ci Signed-off-by: tison <wander4096@gmail.com> * make use of retry lib Signed-off-by: tison <wander4096@gmail.com> * trigger ci Signed-off-by: tison <wander4096@gmail.com> * trigger ci Signed-off-by: tison <wander4096@gmail.com>
SkyWalking Rust Agent provides observability capability for Rust App and Library, including tracing, metrics, topology map for distributed system and alert. It uses SkyWalking native formats and core concepts to keep best compatibility and performance.
All concepts are from the official SkyWalking definitions.
Span is an important and common concept in distributed tracing system. Learn Span from Google Dapper Paper. For better performance, we extend the span into 3 kinds.
Tag and Log are similar attributes of the span.
TracingContext is the context of the tracing process. Span should only be created through context, and be archived into the context after the span finished.
use skywalking_rust::context::trace_context::TracingContext; use skywalking_rust::reporter::grpc::Reporter; use tokio; async fn handle_request(reporter: ContextReporter) { let mut ctx = TracingContext::default("svc", "ins"); { // Generate an Entry Span when a request // is received. An Entry Span is generated only once per context. let span = ctx.create_entry_span("operation1").unwrap(); // Something... { // Generates an Exit Span when executing an RPC. let span2 = ctx.create_exit_span("operation2").unwrap(); // Something... ctx.finalize_span(span2); } ctx.finalize_span(span); } reporter.send(context).await; } #[tokio::main] async fn main() { let tx = Reporter::start("http://0.0.0.0:11800").await; // Start server... }
Apache 2.0