Struct dittolive_ditto::store::collection::Collection

pub struct Collection { /* private fields */ }

A reference to a collection in a Store

Implementations

impl Collection

pub fn name(&self) -> &str

The name of the collection.

pub fn find_all(&self) -> PendingCursorOperation<'_>

Generates a PendingCursorOperation that can be used to find all documents in the collection at a point in time or you can chain a call to PendingCursorOperation::observe_local or PendingCursorOperation::subscribe if you want to get updates about documents in the collection over time. It can also be used to update, remove, or evict documents.

pub fn find(&self, query: &str) -> PendingCursorOperation<'_>

Generates a PendingCursorOperation with the provided query that can be used to find the documents matching the query at a point in time or you can chain a call to PendingCursorOperation::observe_local or PendingCursorOperation::subscribe if you want to get updates about documents matching the query as they occur. It can also be used to update, remove, or evict documents.

pub fn find_with_args<V: Serialize, C: Borrow<V>>( &self, query: &str, query_args: C ) -> PendingCursorOperation<'_>

Generates a PendingCursorOperation with the provided query and query arguments that can be used to find the documents matching the query at a point in time or you can chain a call to PendingCursorOperation::observe_local or PendingCursorOperation::subscribe if you want to get updates about documents matching the query as they occur. It can also be used to update, remove, or evict documents.

This is the recommended function to use when performing queries on a collection if you have any dynamic data included in the query string. It allows you to provide a query string with placeholders, in the form of $args.my_arg_name, along with an accompanying dictionary of arguments, in the form of { "my_arg_name": "some value" }, and the placeholders will be appropriately replaced by the matching provided arguments from the dictionary. This includes handling things like wrapping strings in quotation marks and arrays in square brackets, for example.

pub fn find_by_id( &self, doc_id: impl Into<DocumentId> ) -> PendingIdSpecificOperation

Generates a PendingIdSpecificOperation with the provided document Id that can be used to find the document at a point in time or you can chain a call to PendingIdSpecificOperation::observe_local or PendingIdSpecificOperation::subscribe if you want to get updates about the document over time. It can also be used to update, remove, or evict the document.

impl Collection

pub fn upsert<V: Serialize, C: Borrow<V>>( &self, content: C ) -> Result<DocumentId, DittoError>

Inserts a new document into the collection and returns its Id. If the document already exists, the provided document content will be merged with the existing document’s content.

pub fn upsert_with_strategy<V: Serialize, C: Borrow<V>>( &self, content: C, write_strategy: WriteStrategy ) -> Result<DocumentId, DittoError>

Inserts a new document into the collection and returns its Id. If the document already exists, the behavior is determined by the provided write_strategy.

pub fn new_attachment<P: AsRef<Path>>( &self, filepath: P, metadata: HashMap<String, String> ) -> Result<DittoAttachment, DittoError>

👎Deprecated: Use ditto.store().new_attachment() instead

Creates a new attachment, which can then be inserted into a document.

This API is deprecated. Use ditto.store().new_attachment() instead.

The file residing at the provided path will be copied into the Ditto’s store. The DittoAttachment object that is returned is what you can then use to insert an attachment into a document.

You can provide metadata about the attachment, which will be replicated to other peers alongside the file attachment.

pub fn fetch_attachment<'a>( &self, attachment_token: DittoAttachmentToken, on_fetch_event: impl 'a + Send + Sync + Fn(DittoAttachmentFetchEvent) ) -> Result<DittoAttachmentFetcher<'a, V1>, DittoError>

👎Deprecated: Use ditto.store().fetch_attachment() instead

Fetch the attachment corresponding to the provided attachment token.

This API is deprecated. Use ditto.store().fetch_attachment() instead.

• on_fetch_event: A closure that will be called when the status of the request to fetch the attachment has changed. If the attachment is already available then this will be called almost immediately with a completed status value.

Trait Implementations

impl Clone for Collection

fn clone(&self) -> Collection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Collection

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

Formats the value using the given formatter.