Struct MongoClient 

pub struct MongoClient { /* private fields */ }

A MongoDB client with connection pooling.

The MongoDB driver handles connection pooling internally, so this client wraps the driver’s Client with additional Prax-specific functionality.

Implementations

impl MongoClient

pub async fn new(config: MongoConfig) -> MongoResult<Self>

Create a new client from configuration.

pub fn builder() -> MongoClientBuilder

Create a builder for the client.

pub fn collection<T>(&self, name: &str) -> Collection<T>

where T: Send + Sync,

Get a typed collection.

pub fn collection_doc(&self, name: &str) -> Collection<Document>

Get a collection with BSON documents.

pub fn database(&self) -> &Database

Get the underlying database.

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

Get a different database from the same client.

pub fn inner(&self) -> &Client

Get the underlying MongoDB client.

pub fn config(&self) -> &MongoConfig

Get the configuration.

pub async fn is_healthy(&self) -> bool

Check if the client is healthy by pinging the server.

pub async fn list_collections(&self) -> MongoResult<Vec<String>>

List all collection names in the database.

pub async fn drop_collection(&self, name: &str) -> MongoResult<()>

Drop a collection.

pub async fn create_index( &self, collection: &str, keys: Document, unique: bool, ) -> MongoResult<String>

Create an index on a collection.

pub async fn run_command(&self, command: Document) -> MongoResult<Document>

Run a database command.

pub async fn start_session(&self) -> MongoResult<ClientSession>

Start a client session for transactions.

impl MongoClient

pub async fn create_view(&self, view: &AggregationView) -> MongoResult<()>

Create a view in the database.

pub async fn drop_view(&self, name: &str) -> MongoResult<()>

Drop a view from the database.

pub async fn list_views(&self) -> MongoResult<Vec<String>>

List all views in the database.

pub async fn get_view_definition( &self, name: &str, ) -> MongoResult<Option<AggregationView>>

Get the definition of a view.

pub async fn refresh_materialized_view( &self, view: &MaterializedAggregationView, ) -> MongoResult<u64>

Refresh a materialized view.

This runs the aggregation pipeline and outputs results to the target collection.

Trait Implementations

impl Clone for MongoClient

fn clone(&self) -> MongoClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.