Struct FileStorage

pub struct FileStorage { /* private fields */ }

This storage holds all entities in an SQLite database at the provided path.

Implementations

impl FileStorage

pub fn new(path: &Path) -> FileStorage

Trait Implementations

impl Storage for FileStorage

fn get_resource(&self, at: Timestamp) -> Result<Arc<Resource>, StorageError>

fn get_span(&self, at: Timestamp) -> Result<Arc<Span>, StorageError>

fn get_span_event(&self, at: Timestamp) -> Result<Arc<SpanEvent>, StorageError>

fn get_event(&self, at: Timestamp) -> Result<Arc<Event>, StorageError>

fn get_all_resources(&self) -> Result<StorageIter<'_, Resource>, StorageError>

fn get_all_spans(&self) -> Result<StorageIter<'_, Span>, StorageError>

fn get_all_span_events( &self, ) -> Result<StorageIter<'_, SpanEvent>, StorageError>

fn get_all_events(&self) -> Result<StorageIter<'_, Event>, StorageError>

fn insert_resource(&mut self, resource: Resource) -> Result<(), StorageError>

fn insert_span(&mut self, span: Span) -> Result<(), StorageError>

fn insert_span_event( &mut self, span_event: SpanEvent, ) -> Result<(), StorageError>

fn insert_event(&mut self, event: Event) -> Result<(), StorageError>

fn update_span_closed( &mut self, at: Timestamp, closed: Timestamp, busy: Option<u64>, ) -> Result<(), StorageError>

fn update_span_attributes( &mut self, at: Timestamp, attributes: BTreeMap<String, Value>, ) -> Result<(), StorageError>

fn update_span_link( &mut self, at: Timestamp, link: FullSpanId, attributes: BTreeMap<String, Value>, ) -> Result<(), StorageError>

fn update_span_parents( &mut self, parent_key: SpanKey, spans: &[SpanKey], ) -> Result<(), StorageError>

fn update_event_parents( &mut self, parent_key: SpanKey, events: &[EventKey], ) -> Result<(), StorageError>

fn drop_resources( &mut self, resources: &[Timestamp], ) -> Result<(), StorageError>

fn drop_spans(&mut self, spans: &[Timestamp]) -> Result<(), StorageError>

fn drop_span_events( &mut self, span_events: &[Timestamp], ) -> Result<(), StorageError>

fn drop_events(&mut self, events: &[Timestamp]) -> Result<(), StorageError>