Struct Engine

pub struct Engine { /* private fields */ }

Implementations

impl Engine

pub fn new<S: Storage + Send + 'static>(storage: S) -> Engine

pub fn query_connection( &self, query: Query, ) -> impl Future<Output = Vec<ConnectionView>>

pub fn query_connection_count( &self, query: Query, ) -> impl Future<Output = usize>

pub fn query_span(&self, query: Query) -> impl Future<Output = Vec<SpanView>>

pub fn query_span_count(&self, query: Query) -> impl Future<Output = usize>

pub fn query_span_event( &self, query: Query, ) -> impl Future<Output = Vec<SpanEvent>>

pub fn query_event(&self, query: Query) -> impl Future<Output = Vec<EventView>>

pub fn query_event_count(&self, query: Query) -> impl Future<Output = usize>

pub fn query_stats(&self) -> impl Future<Output = StatsView>

pub fn insert_connection( &self, connection: NewConnection, ) -> impl Future<Output = Result<ConnectionKey, EngineInsertError>>

pub fn disconnect_connection( &self, id: ConnectionId, ) -> impl Future<Output = Result<(), EngineInsertError>>

pub fn insert_span_event( &self, span_event: NewSpanEvent, ) -> impl Future<Output = Result<SpanKey, EngineInsertError>>

pub fn insert_event( &self, event: NewEvent, ) -> impl Future<Output = Result<(), EngineInsertError>>

pub fn delete( &self, filter: DeleteFilter, ) -> impl Future<Output = DeleteMetrics>

pub fn add_attribute_index(&self, name: String)

pub fn remove_attribute_index(&self, name: String)

pub fn subscribe_to_events( &self, filter: Vec<FilterPredicate>, ) -> impl Future<Output = (SubscriptionId, UnboundedReceiver<EventView>)>

pub fn unsubscribe_from_events( &self, id: SubscriptionId, ) -> impl Future<Output = ()>

pub fn copy_dataset( &self, to: Box<dyn Storage + Send>, ) -> impl Future<Output = ()>

pub fn get_status(&self) -> impl Future<Output = EngineStatusView>

Trait Implementations

impl Clone for Engine

fn clone(&self) -> Engine

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.