Struct Reporter 

pub struct Reporter { /* private fields */ }

Implementations

impl Reporter

pub async fn start(address: impl Into<String>) -> Self

Open gRPC client stream to send collected trace context. This function generates a new async task which watch to arrive new trace context. We can send collected context to push into sender.

Example

use std::error::Error;

use tokio;

use skywalking_rust::context::trace_context::TracingContext;
use skywalking_rust::reporter::grpc::Reporter;

#[tokio::main]
async fn main () -> Result<(), Box<dyn Error>> {
    let reporter = Reporter::start("localhost:12800").await;
    let mut context = TracingContext::default("service", "instance");
    reporter.sender().send(context).await?;
    reporter.shutdown().await?;
    Ok(())
}

pub async fn shutdown(self) -> Result<(), Box<dyn Error>>

pub fn sender(&self) -> Sender<TracingContext>