Struct ClientGuard 

struct ClientGuard {
    _tx: Sender<()>,
    client: Client,
}

An async-drop style Guard for mongodb::Client. Use this guard to hold a client, the client::shutdown is called in an async manner when the guard is dropped. Please be aware this is a “best effort” style shutdown, which may not be successful if the tokio runtime is in the process of terminating. However, the server-side resources will be cleaned up eventually due to the session expiration. see this issue for more information

Fields

_tx: Sender<()>

client: Client

Implementations

impl ClientGuard

fn new(name: String, client: Client) -> Self

Methods from Deref<Target = Client>

pub fn bulk_write( &self, models: impl IntoIterator<Item = impl Into<WriteModel>>, ) -> BulkWrite<'_, SummaryBulkWriteResult>

Executes the provided list of write operations.

This operation will retry once upon failure if the connection and encountered error support retryability. See the documentation here for more information on retryable writes.

await will return Result<SummaryBulkWriteResult> or Result<VerboseBulkWriteResult> if verbose_results is configured.

Bulk write is only available on MongoDB 8.0+.

These methods can be chained before .await to set options:

• session
• with_options
• ordered
• bypass_document_validation
• comment
• let_vars
• write_concern
• verbose_results

pub fn list_databases(&self) -> ListDatabases<'_>

Gets information about each database present in the cluster the Client is connected to.

await will return Result<Vec<DatabaseSpecification>>.

These methods can be chained before .await to set options:

• session
• with_options
• authorized_databases
• comment
• filter

pub fn list_database_names(&self) -> ListDatabases<'_, ListNames>

Gets the names of the databases present in the cluster the Client is connected to.

await will return Result<Vec<String>>.

These methods can be chained before .await to set options:

• session
• with_options
• authorized_databases
• comment
• filter

pub fn warm_connection_pool(&self) -> WarmConnectionPool<'_>

Add connections to the connection pool up to min_pool_size. This is normally not needed - the connection pool will be filled in the background, and new connections created as needed up to max_pool_size. However, it can sometimes be preferable to pay the (larger) cost of creating new connections up-front so that individual operations execute as quickly as possible.

Note that topology changes require rebuilding the connection pool, so this method cannot guarantee that the pool will always be filled for the lifetime of the Client.

Does nothing if min_pool_size is unset or zero.

await will return ().

pub fn start_session(&self) -> StartSession<'_>

Starts a new ClientSession.

await will return Result<ClientSession>.

These methods can be chained before .await to set options:

• with_options
• default_transaction_options
• causal_consistency
• snapshot

pub fn watch(&self) -> Watch<'_>

Starts a new ChangeStream that receives events for all changes in the cluster. The stream does not observe changes from system collections or the “config”, “local” or “admin” databases. Note that this method (watch on a cluster) is only supported in MongoDB 4.0 or greater.

See the documentation here on change streams.

Change streams require either a “majority” read concern or no read concern. Anything else will cause a server error.

Note that using a $project stage to remove any of the _id operationType or ns fields will cause an error. The driver requires these fields to support resumability. For more information on resumability, see the documentation for ChangeStream

If the pipeline alters the structure of the returned events, the parsed type will need to be changed via ChangeStream::with_type.

await will return Result<ChangeStream<ChangeStreamEvent<Document>>> or Result<SessionChangeStream<ChangeStreamEvent<Document>>> if a ClientSession has been provided.

These methods can be chained before .await to set options:

• pipeline
• resume_after
• with_options
• full_document
• full_document_before_change
• start_at_operation_time
• start_after
• max_await_time
• batch_size
• collation
• read_concern
• selection_criteria
• show_expanded_events
• comment
• session

pub fn selection_criteria(&self) -> Option<&SelectionCriteria>

Gets the default selection criteria the Client uses for operations..

pub fn read_concern(&self) -> Option<&ReadConcern>

Gets the default read concern the Client uses for operations.

pub fn write_concern(&self) -> Option<&WriteConcern>

Gets the default write concern the Client uses for operations.

pub fn database(&self, name: &str) -> Database

Gets a handle to a database specified by name in the cluster the Client is connected to. The Database options (e.g. read preference and write concern) will default to those of the Client.

This method does not send or receive anything across the wire to the database, so it can be used repeatedly without incurring any costs from I/O.

pub fn database_with_options( &self, name: &str, options: DatabaseOptions, ) -> Database

Gets a handle to a database specified by name in the cluster the Client is connected to. Operations done with this Database will use the options specified by options by default and will otherwise default to those of the Client.

This method does not send or receive anything across the wire to the database, so it can be used repeatedly without incurring any costs from I/O.

pub fn default_database(&self) -> Option<Database>

Gets a handle to the default database specified in the ClientOptions or MongoDB connection string used to construct this Client.

If no default database was specified, None will be returned.

Trait Implementations

impl Deref for ClientGuard

type Target = Client

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.