pub struct SqliteExporter { /* private fields */ }Expand description
Exports metrics by storing them in an SQLite database at a periodic interval
Implementations§
Source§impl SqliteExporter
impl SqliteExporter
Sourcepub fn new<P: AsRef<Path>>(
flush_interval: Duration,
keep_duration: Option<Duration>,
path: P,
) -> Result<Self>
pub fn new<P: AsRef<Path>>( flush_interval: Duration, keep_duration: Option<Duration>, path: P, ) -> Result<Self>
Creates a new SqliteExporter that stores metrics in an SQLite database file.
flush_interval specifies how often metrics are flushed to SQLite/disk
keep_duration specifies how long data is kept. Initial cleanup runs on
the worker, and supplies the default retention for periodic housekeeping.
Opening, migration, and the integrity check still run on the caller.
Sourcepub fn set_periodic_housekeeping(
&self,
periodic_duration: Option<Duration>,
retention: Option<Duration>,
record_limit: Option<usize>,
)
pub fn set_periodic_housekeeping( &self, periodic_duration: Option<Duration>, retention: Option<Duration>, record_limit: Option<usize>, )
Sets optional periodic housekeeping, None to disable (disabled by default)
§Notes
Periodic housekeeping can affect metric recording, causing some data to be dropped during housekeeping.
Exceeding the record limit removes the excess plus 25% of the limit.
retention: None uses the keep_duration supplied to new().
With housekeeping enabled, successful inserts also trigger cleanup after
1,000–100,000 rows (scaled to the record limit), at most once per second.
Deletes run in batches between events. Large amounts of free space may
trigger a full VACUUM on the worker, with attempts at most once per hour.
Disabling periodic housekeeping cancels its pending batches. Startup
cleanup continues independently using the constructor’s retention policy.
Sourcepub fn install(self) -> Result<SqliteExporterHandle, SetRecorderError<Self>>
pub fn install(self) -> Result<SqliteExporterHandle, SetRecorderError<Self>>
Install recorder as metrics crate’s Recorder
Trait Implementations§
Source§impl Drop for SqliteExporter
impl Drop for SqliteExporter
Source§impl Recorder for SqliteExporter
impl Recorder for SqliteExporter
Source§fn describe_counter(
&self,
key: KeyName,
unit: Option<Unit>,
description: SharedString,
)
fn describe_counter( &self, key: KeyName, unit: Option<Unit>, description: SharedString, )
Source§fn describe_gauge(
&self,
key: KeyName,
unit: Option<Unit>,
description: SharedString,
)
fn describe_gauge( &self, key: KeyName, unit: Option<Unit>, description: SharedString, )
Source§fn describe_histogram(
&self,
key: KeyName,
unit: Option<Unit>,
description: SharedString,
)
fn describe_histogram( &self, key: KeyName, unit: Option<Unit>, description: SharedString, )
Auto Trait Implementations§
impl !Freeze for SqliteExporter
impl !RefUnwindSafe for SqliteExporter
impl !UnwindSafe for SqliteExporter
impl Send for SqliteExporter
impl Sync for SqliteExporter
impl Unpin for SqliteExporter
impl UnsafeUnpin for SqliteExporter
Blanket Implementations§
Source§impl<T> AggregateExpressionMethods for T
impl<T> AggregateExpressionMethods for T
Source§fn aggregate_distinct(self) -> Self::Outputwhere
Self: DistinctDsl,
fn aggregate_distinct(self) -> Self::Outputwhere
Self: DistinctDsl,
DISTINCT modifier for aggregate functions Read moreSource§fn aggregate_all(self) -> Self::Outputwhere
Self: AllDsl,
fn aggregate_all(self) -> Self::Outputwhere
Self: AllDsl,
ALL modifier for aggregate functions Read moreSource§fn aggregate_filter<P>(self, f: P) -> Self::Output
fn aggregate_filter<P>(self, f: P) -> Self::Output
Source§fn aggregate_order<O>(self, o: O) -> Self::Outputwhere
Self: OrderAggregateDsl<O>,
fn aggregate_order<O>(self, o: O) -> Self::Outputwhere
Self: OrderAggregateDsl<O>,
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
Source§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
Source§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be
downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.Source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further
downcast into Rc<ConcreteType> where ConcreteType implements Trait.Source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.Source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.Source§impl<T> DowncastSend for T
impl<T> DowncastSend for T
Source§impl<T> DowncastSync for T
impl<T> DowncastSync for T
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoSql for T
impl<T> IntoSql for T
Source§fn into_sql<T>(self) -> Self::Expression
fn into_sql<T>(self) -> Self::Expression
self to an expression for Diesel’s query builder. Read moreSource§fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression
fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression
&self to an expression for Diesel’s query builder. Read more