pub struct DatastoreInstance {
pub db_version: i32,
/* private fields */
}
Fields§
§db_version: i32
Implementations§
Source§impl DatastoreInstance
impl DatastoreInstance
pub fn new( conn: &Connection, migrate_enabled: bool, ) -> Result<DatastoreInstance, DatastoreError>
pub fn ensure_legacy_import(&mut self, conn: &Connection) -> Result<bool, ()>
pub fn create_bucket( &mut self, conn: &Connection, bucket: Bucket, ) -> Result<(), DatastoreError>
pub fn delete_bucket( &mut self, conn: &Connection, bucket_id: &str, ) -> Result<(), DatastoreError>
pub fn get_bucket(&self, bucket_id: &str) -> Result<Bucket, DatastoreError>
pub fn get_buckets(&self) -> HashMap<String, Bucket>
pub fn insert_events( &mut self, conn: &Connection, bucket_id: &str, events: Vec<Event>, ) -> Result<Vec<Event>, DatastoreError>
pub fn delete_events_by_id( &self, conn: &Connection, bucket_id: &str, event_ids: Vec<i64>, ) -> Result<(), DatastoreError>
pub fn replace_last_event( &mut self, conn: &Connection, bucket_id: &str, event: &Event, ) -> Result<(), DatastoreError>
pub fn heartbeat( &mut self, conn: &Connection, bucket_id: &str, heartbeat: Event, pulsetime: f64, last_heartbeat: &mut HashMap<String, Option<Event>>, ) -> Result<Event, DatastoreError>
pub fn get_events( &mut self, conn: &Connection, 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, conn: &Connection, bucket_id: &str, starttime_opt: Option<DateTime<Utc>>, endtime_opt: Option<DateTime<Utc>>, ) -> Result<i64, DatastoreError>
pub fn insert_key_value( &self, conn: &Connection, key: &str, data: &str, ) -> Result<(), DatastoreError>
pub fn delete_key_value( &self, conn: &Connection, key: &str, ) -> Result<(), DatastoreError>
pub fn get_key_value( &self, conn: &Connection, key: &str, ) -> Result<KeyValue, DatastoreError>
pub fn get_keys_starting( &self, conn: &Connection, pattern: &str, ) -> Result<Vec<String>, DatastoreError>
Auto Trait Implementations§
impl Freeze for DatastoreInstance
impl RefUnwindSafe for DatastoreInstance
impl Send for DatastoreInstance
impl Sync for DatastoreInstance
impl Unpin for DatastoreInstance
impl UnwindSafe for DatastoreInstance
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