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,
query: impl Into<Query>,
count: Option<u32>,
) -> Result<Vec<Record>, IndexedDBError>
pub async fn get_all( &mut self, query: impl Into<Query>, count: Option<u32>, ) -> Result<Vec<Record>, IndexedDBError>
Loads every row that matches query.
Sourcepub async fn get_all_keys(
&mut self,
query: impl Into<Query>,
count: Option<u32>,
) -> Result<Vec<String>, IndexedDBError>
pub async fn get_all_keys( &mut self, query: impl Into<Query>, count: Option<u32>, ) -> Result<Vec<String>, IndexedDBError>
Loads every primary key that matches query.
Sourcepub async fn count(
&mut self,
query: impl Into<Query>,
) -> Result<i64, IndexedDBError>
pub async fn count( &mut self, query: impl Into<Query>, ) -> Result<i64, IndexedDBError>
Counts rows that match query.
Sourcepub async fn delete_range(
&mut self,
query: impl Into<Query>,
) -> Result<i64, IndexedDBError>
pub async fn delete_range( &mut self, query: impl Into<Query>, ) -> Result<i64, IndexedDBError>
Deletes rows that match query and returns the delete count.
Sourcepub async fn open_cursor(
&mut self,
query: impl Into<Query>,
direction: CursorDirection,
) -> Result<Cursor, IndexedDBError>
pub async fn open_cursor( &mut self, query: impl Into<Query>, direction: CursorDirection, ) -> Result<Cursor, IndexedDBError>
Opens a full-value cursor over the object store.
Sourcepub async fn open_key_cursor(
&mut self,
query: impl Into<Query>,
direction: CursorDirection,
) -> Result<Cursor, IndexedDBError>
pub async fn open_key_cursor( &mut self, query: impl Into<Query>, 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,
query: Query,
) -> 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,
query: Query,
) -> Pin<Box<dyn Future<Output = Result<Vec<Record>, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Loads every row that matches query.
Source§fn get_all_keys<'life0, 'async_trait>(
&'life0 mut self,
query: Query,
) -> 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,
query: Query,
) -> 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 query.
Source§fn count<'life0, 'async_trait>(
&'life0 mut self,
query: Query,
) -> 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,
query: Query,
) -> Pin<Box<dyn Future<Output = Result<i64, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Counts rows that match query.
Source§fn delete_range<'life0, 'async_trait>(
&'life0 mut self,
query: Query,
) -> 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,
query: Query,
) -> Pin<Box<dyn Future<Output = Result<i64, IndexedDBError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Deletes rows that match query and returns the delete count.
Source§fn open_cursor<'life0, 'async_trait>(
&'life0 mut self,
query: Query,
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,
query: Query,
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,
query: Query,
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,
query: Query,
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