Struct otlp_embedded::TraceServiceImpl

pub struct TraceServiceImpl { /* private fields */ }

The implementation of TraceService.

Implementations

impl TraceServiceImpl

pub fn new(state: Arc<RwLock<State>>) -> Self

Create a new TraceServiceImpl with the given State reference.

Examples found in repository

examples/basic.rs (line 16)

async fn main() {
    let state = State::new(100);
    let state_clone = state.clone();

    tokio::spawn(async {
        axum::Server::bind(&"0.0.0.0:10188".parse().unwrap())
            .serve(ui_app(state, "/").into_make_service())
            .await
            .unwrap();
    });

    tonic::transport::Server::builder()
        .add_service(TraceServiceServer::new(TraceServiceImpl::new(state_clone)))
        .serve("0.0.0.0:43177".parse().unwrap())
        .await
        .unwrap();
}

Trait Implementations

impl TraceService for TraceServiceImpl

fn export<'life0, 'async_trait>( &'life0 self, request: Request<ExportTraceServiceRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<ExportTraceServiceResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

For performance reasons, it is recommended to keep this RPC alive for the entire life of the application.