Struct qldb::QldbClient

pub struct QldbClient { /* private fields */ }

It allows to start transactions. In QLDB all queries are transactions. So you always need to create a transaction for every query.

The recommended method is transaction_within.

Implementations

impl QldbClient

pub async fn default(
    ledger_name: &str,
    max_sessions: u16
) -> QldbResult<QldbClient>

Creates a new QldbClient.

This function will take the credentials from several locations in this order:

• Environment variables: AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY
• credential_process command in the AWS config file, usually located at ~/.aws/config.
• AWS credentials file. Usually located at ~/.aws/credentials.
• IAM instance profile. Will only work if running on an EC2 instance with an instance profile/role.

https://docs.rs/rusoto_credential/0.45.0/rusoto_credential/struct.ChainProvider.html

For the region it will will attempt to read the AWS_DEFAULT_REGION or AWS_REGION environment variable. If it is malformed, it will fall back to Region::UsEast1. If it is not present it will fallback on the value associated with the current profile in ~/.aws/config or the file specified by the AWS_CONFIG_FILE environment variable. If that is malformed of absent it will fall back on Region::UsEast1

pub async fn read_query(&self, statement: &str) -> QldbResult<QueryBuilder>

Shorthand method that creates a transaction and executes a query. Currently it doesn’t filter by statements, so any statement can be sent but it won’t have effect as it will rollback any change. This allows to read big quantities of data without failing other transactions that may be reading that data at the same time.

This is a good option when you want to execute an isolated non-ACID SELECT/COUNT statement.

pub async fn transaction(&self) -> QldbResult<Transaction>

Starts a transaction and returns you the transaction handler. When using this method the transaction won’t automatically commit or rollback when finished. If they are left open they will be canceled when the transaction times out on the DB side (30 seconds).

Use this method if you really need to use the transaction handler directly. If not, you may be better off using the method transaction_within.

pub async fn close(&mut self)

It closes the session pool. Current transaction which already have a session can work as normal, but new transaction (requiring a new session id) will return error.

Call this method only when you are sure that all important work is already commited to QLDB.

pub async fn transaction_within<F, R, FR>(&self, clousure: F) -> QldbResult<R> where
    R: Debug,
    FR: Future<Output = QldbResult<R>>,
    F: FnOnce(Transaction) -> FR, 

It call the closure providing an already made transaction. Once the closure finishes it will call commit or rollback if any error.

Trait Implementations

impl Clone for QldbClient

fn clone(&self) -> QldbClient

Returns a copy of the value.

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

Performs copy-assignment from source.