Struct mungos::Collection

pub struct Collection<T> {
    pub db: Database,
    pub collection: Collection<T>,
}

Fields

db: Database

collection: Collection<T>

Implementations

impl<T> Collection<T>

pub async fn create_index(&self, field: &str) -> Result<CreateIndexResult>

pub async fn create_unique_index(&self, field: &str) -> Result<CreateIndexResult>

pub async fn create_index_from_doc(
    &self,
    index_doc: Document
) -> Result<CreateIndexResult>

pub async fn create_unique_index_from_doc(
    &self,
    index_doc: Document
) -> Result<CreateIndexResult>

impl<T: DeserializeOwned + Unpin + Send + Sync> Collection<T>

pub async fn aggregate(
    &self,
    pipeline: impl IntoIterator<Item = impl Into<Document>>,
    options: impl Into<Option<AggregateOptions>>
) -> Result<Cursor<Document>>

pub async fn aggregate_collect(
    &self,
    pipeline: impl IntoIterator<Item = impl Into<Document>>,
    options: impl Into<Option<AggregateOptions>>
) -> Result<Vec<Document>>

impl<T> Collection<T>

pub async fn bulk_upsert(
    &self,
    updates: impl Borrow<Vec<BulkUpsert>>
) -> Result<Document>

impl<T: Serialize> Collection<T>

pub async fn create_many(
    &self,
    items: impl IntoIterator<Item = impl Borrow<T>>
) -> Result<()>

impl<T: Serialize> Collection<T>

pub async fn create_one(&self, item: impl Borrow<T>) -> Result<String>

impl<T> Collection<T>

pub async fn delete_many(&self, filter: Document) -> Result<DeleteResult>

impl<T> Collection<T>

pub async fn delete_one(&self, id: &str) -> Result<String>

impl<T: DeserializeOwned + Unpin + Send + Sync> Collection<T>

pub async fn find_one(
    &self,
    filter: impl Into<Option<Document>>,
    options: impl Into<Option<FindOneOptions>>
) -> Result<Option<T>>

pub async fn find_one_by_id(&self, id: &str) -> Result<Option<T>>

impl<T: DeserializeOwned + Unpin + Send + Sync> Collection<T>

pub async fn get_many_by_id(
    &self,
    ids: &Vec<String>,
    options: impl Into<Option<FindOptions>>
) -> Result<Vec<T>>

impl<T: DeserializeOwned + Unpin + Send + Sync> Collection<T>

pub async fn get_most_recent(
    &self,
    index: &str,
    limit: i64,
    offset: u64,
    filter: impl Into<Option<Document>>,
    projection: impl Into<Option<Document>>
) -> Result<Vec<T>>

impl<T: DeserializeOwned + Unpin + Send + Sync> Collection<T>

pub async fn get_some(
    &self,
    filter: impl Into<Option<Document>>,
    find_options: impl Into<Option<FindOptions>>
) -> Result<Vec<T>>

impl<T: DeserializeOwned + Unpin + Send + Sync> Collection<T>

pub async fn get_sorted_cursor(
    &self,
    filter: impl Into<Option<Document>>,
    sort_field: &str,
    sort_direction: SortDirection,
    batch_size: impl Into<Option<u32>>,
    numeric_ordering: impl Into<Option<bool>>
) -> Result<Cursor<T>>

impl<T: DeserializeOwned + Unpin + Send + Sync> Collection<T>

pub async fn most_recent_by_cursor(
    &self,
    most_recent_by_field: &str,
    num_items: i64,
    offset: u64,
    filter: impl Into<Option<Document>>,
    projection: impl Into<Option<Document>>
) -> Result<Cursor<T>>

impl<Any> Collection<Any>

pub async fn update_many(&self, query: Document, update: Document) -> Result<()>

impl<Any> Collection<Any>

pub async fn update_one<T: Serialize>(
    &self,
    id: &str,
    update: Update<T>
) -> Result<()>

impl<T> Collection<T>

pub async fn upsert(
    &self,
    query: Document,
    update: impl Into<UpdateModifications>
) -> Result<UpdateResult>

Trait Implementations

impl<T: Clone> Clone for Collection<T>

fn clone(&self) -> Collection<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Collection<T>

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

Formats the value using the given formatter.