Struct Datastore

pub struct Datastore { /* private fields */ }

Implementations

impl Datastore

pub fn new(dbpath: String, legacy_import: bool) -> Self

pub fn new_in_memory(legacy_import: bool) -> Self

pub fn create_bucket(&self, bucket: &Bucket) -> Result<(), DatastoreError>

pub fn delete_bucket(&self, bucket_id: &str) -> Result<(), DatastoreError>

pub fn get_bucket(&self, bucket_id: &str) -> Result<Bucket, DatastoreError>

pub fn get_buckets(&self) -> Result<HashMap<String, Bucket>, DatastoreError>

pub fn insert_events( &self, bucket_id: &str, events: &[Event], ) -> Result<Vec<Event>, DatastoreError>

pub fn heartbeat( &self, bucket_id: &str, heartbeat: Event, pulsetime: f64, ) -> Result<Event, DatastoreError>

pub fn get_events( &self, bucket_id: &str, starttime_opt: Option<DateTime<Utc>>, endtime_opt: Option<DateTime<Utc>>, limit_opt: Option<u64>, ) -> Result<Vec<Event>, DatastoreError>

pub fn get_event_count( &self, bucket_id: &str, starttime_opt: Option<DateTime<Utc>>, endtime_opt: Option<DateTime<Utc>>, ) -> Result<i64, DatastoreError>

pub fn delete_events_by_id( &self, bucket_id: &str, event_ids: Vec<i64>, ) -> Result<(), DatastoreError>

pub fn force_commit(&self) -> Result<(), DatastoreError>

pub fn insert_key_value( &self, key: &str, data: &str, ) -> Result<(), DatastoreError>

pub fn delete_key_value(&self, key: &str) -> Result<(), DatastoreError>

pub fn get_key_value(&self, key: &str) -> Result<KeyValue, DatastoreError>

pub fn get_keys_starting( &self, pattern: &str, ) -> Result<Vec<String>, DatastoreError>

Trait Implementations

impl Clone for Datastore

fn clone(&self) -> Datastore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Datastore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.