pub struct SqliteQualityTelemetryWriter { /* private fields */ }Expand description
Multi-process SQLite writer for the bounded local quality journal.
Implementations§
Source§impl SqliteQualityTelemetryWriter
impl SqliteQualityTelemetryWriter
pub fn reader(&self) -> SqliteQualityTelemetryReader
pub fn open( data_dir: &Path, retention: QualityTelemetryRetention, ) -> Result<Self, PortError>
pub fn open_with_durable_interval( data_dir: &Path, retention: QualityTelemetryRetention, durable_every_batches: u64, ) -> Result<Self, PortError>
pub fn migrated_legacy_observations(&self) -> u64
pub fn write_batch( &self, observations: &[QualityTelemetryObservation], ) -> Result<(), PortError>
pub fn flush_durable(&self) -> Result<(), PortError>
pub fn write_failures(&self) -> u64
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for SqliteQualityTelemetryWriter
impl RefUnwindSafe for SqliteQualityTelemetryWriter
impl Send for SqliteQualityTelemetryWriter
impl Sync for SqliteQualityTelemetryWriter
impl Unpin for SqliteQualityTelemetryWriter
impl UnsafeUnpin for SqliteQualityTelemetryWriter
impl UnwindSafe for SqliteQualityTelemetryWriter
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more