Struct otlp_embedded::State

pub struct State { /* private fields */ }

In-memory state that maintains the most recent traces.

Old traces that are no longer updated or accessed will be evicted when the capacity is reached.

Implementations

impl State

pub fn new(recent: u32) -> StateRef

Create a new State with the given number of recent traces to keep.

Examples found in repository

examples/basic.rs (line 5)

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();
}

pub fn get_by_id(&mut self, id: &[u8]) -> Option<Trace>

Get a trace by its ID.

The trace will be promoted to the most recent.

pub fn get_all_complete(&self) -> impl Iterator<Item = Trace> + '_

Get an iterator over all traces that are complete.

pub fn get_all_services(&self) -> BTreeSet<&str>

Get a set of all services.

pub fn get_operations(&self, service_name: &str) -> BTreeSet<&str>

Get a set of all operations for the given service.