pub struct ObjectStore { /* private fields */ }Expand description
CRUD, range-query, and cursor access for one object store.
Implementations§
Source§impl ObjectStore
impl ObjectStore
Sourcepub async fn get(&mut self, id: &str) -> Result<Record, IndexedDBError>
pub async fn get(&mut self, id: &str) -> Result<Record, IndexedDBError>
Loads one record by primary key.
Sourcepub async fn get_key(&mut self, id: &str) -> Result<String, IndexedDBError>
pub async fn get_key(&mut self, id: &str) -> Result<String, IndexedDBError>
Resolves the primary key for id.
Sourcepub async fn add(&mut self, record: Record) -> Result<(), IndexedDBError>
pub async fn add(&mut self, record: Record) -> Result<(), IndexedDBError>
Inserts a new row and fails if the key already exists.
Sourcepub async fn put(&mut self, record: Record) -> Result<(), IndexedDBError>
pub async fn put(&mut self, record: Record) -> Result<(), IndexedDBError>
Upserts a row by primary key.
Sourcepub async fn delete(&mut self, id: &str) -> Result<(), IndexedDBError>
pub async fn delete(&mut self, id: &str) -> Result<(), IndexedDBError>
Deletes one row by primary key.
Sourcepub async fn clear(&mut self) -> Result<(), IndexedDBError>
pub async fn clear(&mut self) -> Result<(), IndexedDBError>
Deletes every row in the object store.
Sourcepub async fn get_all(
&mut self,
range: Option<KeyRange>,
) -> Result<Vec<Record>, IndexedDBError>
pub async fn get_all( &mut self, range: Option<KeyRange>, ) -> Result<Vec<Record>, IndexedDBError>
Loads every row that matches range.
Sourcepub async fn get_all_keys(
&mut self,
range: Option<KeyRange>,
) -> Result<Vec<String>, IndexedDBError>
pub async fn get_all_keys( &mut self, range: Option<KeyRange>, ) -> Result<Vec<String>, IndexedDBError>
Loads every primary key that matches range.
Sourcepub async fn count(
&mut self,
range: Option<KeyRange>,
) -> Result<i64, IndexedDBError>
pub async fn count( &mut self, range: Option<KeyRange>, ) -> Result<i64, IndexedDBError>
Counts rows that match range.
Sourcepub async fn delete_range(
&mut self,
range: KeyRange,
) -> Result<i64, IndexedDBError>
pub async fn delete_range( &mut self, range: KeyRange, ) -> Result<i64, IndexedDBError>
Deletes rows that match range and returns the delete count.
Sourcepub async fn open_cursor(
&mut self,
range: Option<KeyRange>,
direction: CursorDirection,
) -> Result<Cursor, IndexedDBError>
pub async fn open_cursor( &mut self, range: Option<KeyRange>, direction: CursorDirection, ) -> Result<Cursor, IndexedDBError>
Opens a full-value cursor over the object store.
Sourcepub async fn open_key_cursor(
&mut self,
range: Option<KeyRange>,
direction: CursorDirection,
) -> Result<Cursor, IndexedDBError>
pub async fn open_key_cursor( &mut self, range: Option<KeyRange>, direction: CursorDirection, ) -> Result<Cursor, IndexedDBError>
Opens a key-only cursor over the object store.
Trait Implementations§
Source§impl ObjectStoreApi for ObjectStore
impl ObjectStoreApi for ObjectStore
Source§fn get<'life0, 'life1, 'async_trait>(
&'life0 mut self,
id: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<Record, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get<'life0, 'life1, 'async_trait>(
&'life0 mut self,
id: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<Record, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Loads one record by primary key.
Source§fn get_key<'life0, 'life1, 'async_trait>(
&'life0 mut self,
id: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<String, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_key<'life0, 'life1, 'async_trait>(
&'life0 mut self,
id: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<String, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Resolves the primary key for id.
Source§fn add<'life0, 'async_trait>(
&'life0 mut self,
record: Record,
) -> Pin<Box<dyn Future<Output = Result<(), IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn add<'life0, 'async_trait>(
&'life0 mut self,
record: Record,
) -> Pin<Box<dyn Future<Output = Result<(), IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Inserts a new row and fails if the key already exists.
Source§fn put<'life0, 'async_trait>(
&'life0 mut self,
record: Record,
) -> Pin<Box<dyn Future<Output = Result<(), IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn put<'life0, 'async_trait>(
&'life0 mut self,
record: Record,
) -> Pin<Box<dyn Future<Output = Result<(), IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Upserts a row by primary key.
Source§fn delete<'life0, 'life1, 'async_trait>(
&'life0 mut self,
id: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<(), IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn delete<'life0, 'life1, 'async_trait>(
&'life0 mut self,
id: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<(), IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Deletes one row by primary key.
Source§fn clear<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<(), IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn clear<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<(), IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Deletes every row in the object store.
Source§fn get_all<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
) -> Pin<Box<dyn Future<Output = Result<Vec<Record>, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_all<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
) -> Pin<Box<dyn Future<Output = Result<Vec<Record>, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Loads every row that matches range.
Source§fn get_all_keys<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
) -> Pin<Box<dyn Future<Output = Result<Vec<String>, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_all_keys<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
) -> Pin<Box<dyn Future<Output = Result<Vec<String>, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Loads every primary key that matches range.
Source§fn count<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
) -> Pin<Box<dyn Future<Output = Result<i64, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn count<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
) -> Pin<Box<dyn Future<Output = Result<i64, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Counts rows that match range.
Source§fn delete_range<'life0, 'async_trait>(
&'life0 mut self,
range: KeyRange,
) -> Pin<Box<dyn Future<Output = Result<i64, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn delete_range<'life0, 'async_trait>(
&'life0 mut self,
range: KeyRange,
) -> Pin<Box<dyn Future<Output = Result<i64, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Deletes rows that match range and returns the delete count.
Source§fn open_cursor<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
direction: CursorDirection,
) -> Pin<Box<dyn Future<Output = Result<Cursor, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn open_cursor<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
direction: CursorDirection,
) -> Pin<Box<dyn Future<Output = Result<Cursor, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Opens a full-value cursor over the object store.
Source§fn open_key_cursor<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
direction: CursorDirection,
) -> Pin<Box<dyn Future<Output = Result<Cursor, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn open_key_cursor<'life0, 'async_trait>(
&'life0 mut self,
range: Option<KeyRange>,
direction: CursorDirection,
) -> Pin<Box<dyn Future<Output = Result<Cursor, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Opens a key-only cursor over the object store.
Auto Trait Implementations§
impl !Freeze for ObjectStore
impl !RefUnwindSafe for ObjectStore
impl !UnwindSafe for ObjectStore
impl Send for ObjectStore
impl Sync for ObjectStore
impl Unpin for ObjectStore
impl UnsafeUnpin for ObjectStore
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
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request