Trait mongodb::ThreadedClient

pub trait ThreadedClient: Sync + Sized {
    fn connect(host: &str, port: u16) -> Result<Self>;
    fn connect_with_options(host: &str, port: u16, ClientOptions) -> Result<Self>;
    fn with_uri(uri: &str) -> Result<Self>;
    fn with_uri_and_options(uri: &str, options: ClientOptions) -> Result<Self>;
    fn with_config(config: ConnectionString,
               options: Option<ClientOptions>,
               description: Option<TopologyDescription>)
               -> Result<Self>;
    fn db(&self, db_name: &str) -> Database;
    fn db_with_prefs(&self,
                 db_name: &str,
                 read_preference: Option<ReadPreference>,
                 write_concern: Option<WriteConcern>)
                 -> Database;
    fn acquire_stream(&self,
                  read_pref: ReadPreference)
                  -> Result<(PooledStream, bool, bool)>;
    fn acquire_write_stream(&self) -> Result<PooledStream>;
    fn get_req_id(&self) -> i32;
    fn database_names(&self) -> Result<Vec<String>>;
    fn drop_database(&self, db_name: &str) -> Result<()>;
    fn is_master(&self) -> Result<bool>;
    fn add_start_hook(&mut self, hook: fn(Client, &CommandStarted)) -> Result<()>;
    fn add_completion_hook(&mut self,
                       hook: fn(Client, &CommandResult))
                       -> Result<()>;
}

Required Methods

fn connect(host: &str, port: u16) -> Result<Self>

Creates a new Client directly connected to a single MongoDB server.

fn connect_with_options(host: &str, port: u16, ClientOptions) -> Result<Self>

Creates a new Client directly connected to a single MongoDB server with options.

fn with_uri(uri: &str) -> Result<Self>

Creates a new Client connected to a complex topology, such as a replica set or sharded cluster.

fn with_uri_and_options(uri: &str, options: ClientOptions) -> Result<Self>

Creates a new Client connected to a complex topology, such as a replica set or sharded cluster, with options.

fn with_config(config: ConnectionString,
               options: Option<ClientOptions>,
               description: Option<TopologyDescription>)
               -> Result<Self>

Create a new Client with manual connection configurations. connect and with_uri should generally be used as higher-level constructors.

fn db(&self, db_name: &str) -> Database

Creates a database representation.

fn db_with_prefs(&self,
                 db_name: &str,
                 read_preference: Option<ReadPreference>,
                 write_concern: Option<WriteConcern>)
                 -> Database

Creates a database representation with custom read and write controls.

fn acquire_stream(&self,
                  read_pref: ReadPreference)
                  -> Result<(PooledStream, bool, bool)>

Acquires a connection stream from the pool, along with slave_ok and should_send_read_pref.

fn acquire_write_stream(&self) -> Result<PooledStream>

Acquires a connection stream from the pool for write operations.

fn get_req_id(&self) -> i32

Returns a unique operational request id.

fn database_names(&self) -> Result<Vec<String>>

Returns a list of all database names that exist on the server.

fn drop_database(&self, db_name: &str) -> Result<()>

Drops the database defined by db_name.

fn is_master(&self) -> Result<bool>

Reports whether this instance is a primary, master, mongos, or standalone mongod instance.

fn add_start_hook(&mut self, hook: fn(Client, &CommandStarted)) -> Result<()>

Sets a function to be run every time a command starts.

fn add_completion_hook(&mut self,
                       hook: fn(Client, &CommandResult))
                       -> Result<()>

Sets a function to be run every time a command completes.

Implementors

• impl ThreadedClient for Client