Struct SyncEngine

pub struct SyncEngine<S> { /* private fields */ }

Provides the core engine functionality.

Implementations

impl<S: Storage> SyncEngine<S>

pub fn new(storage: S) -> Result<SyncEngine<S>, AnyError>

pub fn query_event(&self, query: Query) -> Vec<ComposedEvent>

pub fn query_event_count(&self, query: Query) -> usize

pub fn query_span(&self, query: Query) -> Vec<ComposedSpan>

pub fn query_span_count(&self, query: Query) -> usize

pub fn query_stats(&self) -> DatasetStats

pub fn insert_resource( &mut self, resource: NewResource, ) -> Result<ResourceKey, AnyError>

pub fn disconnect_tracing_instance( &mut self, instance_id: InstanceId, ) -> Result<(), AnyError>

pub fn insert_span_event( &mut self, new_span_event: NewSpanEvent, ) -> Result<SpanEventKey, AnyError>

pub fn insert_event(&mut self, new_event: NewEvent) -> Result<(), AnyError>

pub fn delete( &mut self, filter: DeleteFilter, ) -> Result<DeleteMetrics, AnyError>

pub fn copy_dataset( &self, target_storage: &mut dyn Storage, ) -> Result<(), AnyError>

pub fn subscribe_to_spans( &mut self, filter: Vec<FilterPredicate>, ) -> Result<(SubscriptionId, UnboundedReceiver<SubscriptionResponse<ComposedSpan>>), AnyError>

pub fn unsubscribe_from_spans(&mut self, id: SubscriptionId)

pub fn subscribe_to_events( &mut self, filter: Vec<FilterPredicate>, ) -> Result<(SubscriptionId, UnboundedReceiver<SubscriptionResponse<ComposedEvent>>), AnyError>

pub fn unsubscribe_from_events(&mut self, id: SubscriptionId)

pub fn shutdown(&mut self) -> Result<(), AnyError>