Crate deadpool_amqprs 

deadpool-amqprs

Deadpool for amqprs

Deadpool is a dead simple async pool for connections and objects of any type.

This crate implements a deadpool manager for amqprs.

Versions

• v0.2.x - amqprs 0.9.x
• v0.3.x - amqprs 0.10.x

Example

use deadpool_amqprs::Config;
use amqprs::{callbacks::{DefaultChannelCallback, DefaultConnectionCallback}, connection::OpenConnectionArguments};

#[tokio::main]
async fn main() {
    let config = Config::new_with_con_args(OpenConnectionArguments::default());
    let pool = config.create_pool();
    
    let con = pool.get().await.unwrap();
    con.register_callback(DefaultConnectionCallback).await.unwrap();

    let channel = con.open_channel().await.unwrap();
    channel.register_callback(DefaultChannelCallback).await.unwrap();

    // Do stuff with `channel`.
}

Re-exports

pub use config::Config;

pub use config::ConfigError;

pub use amqprs;

Modules

config

Structs

Manager

Manager for creating and recycling amqprs connections.

Metrics

Statistics regarding an object returned by the pool

ObjectId

A unique identifier for an object within a pool.

PoolConfig

Pool configuration.

Status

The current pool status.

Timeouts

Timeouts when getting Objects from a Pool.

Enums

Runtime

Enumeration for picking a runtime implementation.

TimeoutType

Possible steps causing the timeout in an error returned by Pool::get() method.

Type Aliases

BuildError

Type alias for using deadpool::managed::BuildError with amqprs.

Connection

Type alias for Object in case Object isn’t straight foward enough.

CreatePoolError

Type alias for using deadpool::managed::CreatePoolError with amqprs.

Hook

Type alias for using deadpool::managed::Hook with amqprs.

HookError

Type alias for using deadpool::managed::HookError with amqprs.

Object

Type alias for using deadpool::managed::Object with amqprs.

Pool

Type alias for using deadpool::managed::Pool with amqprs.

PoolBuilder

Type alias for using deadpool::managed::PoolBuilder with amqprs.

PoolError

Type alias for using deadpool::managed::PoolError with amqprs.

WeakPool

Type alias for using deadpool::managed::Pool with amqprs.